add processEVery
This commit is contained in:
1 parent
707b8f903b
commit
f85f1aa1d1
1 file changed
+1
@@ -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);
|
||||
|
||||
Reference in new issue
Block a user