diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts index c6f30da93f..239b489736 100644 --- a/packages/backend/src/core/QueueService.ts +++ b/packages/backend/src/core/QueueService.ts @@ -269,6 +269,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -279,6 +282,9 @@ export class QueueService { }, { removeOnComplete: true, removeOnFail: true, + deduplication: { + id: user.id, + }, }); } @@ -295,6 +301,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -311,6 +320,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -327,6 +339,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -345,6 +360,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -361,6 +379,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -377,6 +398,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -393,6 +417,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); } @@ -409,6 +436,9 @@ export class QueueService { age: 3600 * 24 * 7, // keep up to 7 days count: 100, }, + deduplication: { + id: user.id, + }, }); }