fix(queue-worker): concurrency
This commit is contained in:
@@ -102,7 +102,7 @@ const workerFun = async (queueName: string, processJobInternal: (token: string,
|
|||||||
|
|
||||||
const job = await worker.getNextJob(token);
|
const job = await worker.getNextJob(token);
|
||||||
if (job) {
|
if (job) {
|
||||||
await processJobInternal(token, job);
|
processJobInternal(token, job);
|
||||||
await sleep(gotJobInterval);
|
await sleep(gotJobInterval);
|
||||||
} else {
|
} else {
|
||||||
await sleep(connectionMonitorInterval);
|
await sleep(connectionMonitorInterval);
|
||||||
|
|||||||
Reference in New Issue
Block a user