diff --git a/apps/api/src/services/queues/data-gathering/data-gathering.module.ts b/apps/api/src/services/queues/data-gathering/data-gathering.module.ts index 5ac6c40c0..7258c034c 100644 --- a/apps/api/src/services/queues/data-gathering/data-gathering.module.ts +++ b/apps/api/src/services/queues/data-gathering/data-gathering.module.ts @@ -29,6 +29,7 @@ import { DataGatheringProcessor } from './data-gathering.processor'; BullModule.registerQueue({ limiter: { duration: ms('4 seconds'), + groupKey: 'dataSource', max: 1 }, name: DATA_GATHERING_QUEUE