Merge pull request #40 from mudkipme/develop

fix: remove old jobs
mudkipme · Sep 3, 2023 · e565a8b · e565a8b
2 parents 8758734 + 9a96eb2
commit e565a8b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/klinklang-server/src/lib/worker.ts b/packages/klinklang-server/src/lib/worker.ts
@@ -10,7 +10,9 @@ export const getWorker = ({ config, logger }: { config: Config, logger: Logger }
     return await processAction(job)
   }, {
     connection: config.get('redis'),
-    autorun: false
+    autorun: false,
+    removeOnComplete: { count: 1000 },
+    removeOnFail: { count: 1000 }
   })
 
   worker.on('failed', (job, err) => {