alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update: auto-removal of completed jobs

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-02-12 02:13:42 +08:00
parent 7797fef685
commit dd7cdc4db5
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/worker.ts
View File

@ -31,7 +31,7 @@ Deno.addSignalListener("SIGTERM", async () => {
await latestVideoWorker.close(true); await latestVideoWorker.close(true);
await videoTagsWorker.close(true); await videoTagsWorker.close(true);
Deno.exit(); Deno.exit();
}) });
const latestVideoWorker = new Worker( const latestVideoWorker = new Worker(
"latestVideos", "latestVideos",
@ -44,7 +44,7 @@ const latestVideoWorker = new Worker(
break; break;
} }
}, },
{ connection: redis, concurrency: 1 }, { connection: redis, concurrency: 1, removeOnComplete: { count: 1440 } },
); );
latestVideoWorker.on("active", () => { latestVideoWorker.on("active", () => {
@ -72,7 +72,13 @@ const videoTagsWorker = new Worker(
break; break;
} }
}, },
{ connection: redis, concurrency: 6 }, {
connection: redis,
concurrency: 6,
removeOnComplete: {
count: 1000,
},
},
); );
videoTagsWorker.on("active", () => { videoTagsWorker.on("active", () => {