From 7c5cda7b45325b2fcbc9ba2b46239986f9138372 Mon Sep 17 00:00:00 2001
From: Gergo Moricz <mo.geryy@gmail.com>
Date: Tue, 6 Aug 2024 16:57:00 +0200
Subject: [PATCH] fix(queue-worker): concurrency

---
 apps/api/src/services/queue-worker.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);