diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts index 99911f38a7..344ea2ab40 100644 --- a/packages/backend/src/core/QueueService.ts +++ b/packages/backend/src/core/QueueService.ts @@ -940,15 +940,6 @@ export class QueueService implements OnModuleInit { data.type, data, { - removeOnComplete: { - age: 3600 * 24 * 7, // keep up to 7 days - count: 30, - }, - removeOnFail: { - age: 3600 * 24 * 7, // keep up to 7 days - count: 100, - }, - // https://docs.bullmq.io/guide/retrying-failing-jobs#custom-back-off-strategies attempts: this.config.backgroundJobMaxAttempts ?? 8, backoff: { diff --git a/packages/backend/src/queue/QueueProcessorService.ts b/packages/backend/src/queue/QueueProcessorService.ts index b04d19618f..0124660227 100644 --- a/packages/backend/src/queue/QueueProcessorService.ts +++ b/packages/backend/src/queue/QueueProcessorService.ts @@ -591,6 +591,16 @@ export class QueueProcessorService implements OnApplicationShutdown { settings: { backoffStrategy: httpRelatedBackoff, }, + // Keep a lot of jobs, because this queue moves *fast*! + // https://docs.bullmq.io/guide/workers/auto-removal-of-jobs + removeOnComplete: { + age: 3600 * 24 * 7, // keep up to 7 days + count: 1000, + }, + removeOnFail: { + age: 3600 * 24 * 7, // keep up to 7 days + count: 1000, + }, }); this.backgroundTaskWorker .on('active', (job) => logger.debug(`active id=${job.id}`))