From dd7cdc4db5641ac40a37b1c82a6c48ae3915393e Mon Sep 17 00:00:00 2001 From: alikia2x Date: Wed, 12 Feb 2025 02:13:42 +0800 Subject: [PATCH] update: auto-removal of completed jobs --- src/worker.ts | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/worker.ts b/src/worker.ts index 98ed995..fc483ed 100644 --- a/src/worker.ts +++ b/src/worker.ts @@ -31,7 +31,7 @@ Deno.addSignalListener("SIGTERM", async () => { await latestVideoWorker.close(true); await videoTagsWorker.close(true); Deno.exit(); -}) +}); const latestVideoWorker = new Worker( "latestVideos", @@ -44,7 +44,7 @@ const latestVideoWorker = new Worker( break; } }, - { connection: redis, concurrency: 1 }, + { connection: redis, concurrency: 1, removeOnComplete: { count: 1440 } }, ); latestVideoWorker.on("active", () => { @@ -72,7 +72,13 @@ const videoTagsWorker = new Worker( break; } }, - { connection: redis, concurrency: 6 }, + { + connection: redis, + concurrency: 6, + removeOnComplete: { + count: 1000, + }, + }, ); videoTagsWorker.on("active", () => {