diff --git a/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts b/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts index 4bb88e101..51dcd9460 100644 --- a/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts +++ b/server/src/service/infrastructure/JobQueues/LessSimpleQueue.ts @@ -142,6 +142,7 @@ export class LessSimpleQueue implements IJobQueue { }); const scheduler = new Scheduler(store, { concurrency: envSettings.queueMode === "primary" ? 0 : 50, + processEvery: 100, }); const instance = new LessSimpleQueue(logger, helper, monitorsRepository, workersRepository, scheduler, queueMode); await instance.init(queueMode);