diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts index ca9d5977..e660378b 100644 --- a/apps/api/src/services/queue-worker.ts +++ b/apps/api/src/services/queue-worker.ts @@ -102,7 +102,7 @@ const workerFun = async (queueName: string, processJobInternal: (token: string, const job = await worker.getNextJob(token); if (job) { - await processJobInternal(token, job); + processJobInternal(token, job); await sleep(gotJobInterval); } else { await sleep(connectionMonitorInterval);