From a1c2ee5aa94995d4745f3e1870c7dfecfde15424 Mon Sep 17 00:00:00 2001
From: Gergo Moricz <mo.geryy@gmail.com>
Date: Wed, 7 Aug 2024 19:39:09 +0200
Subject: [PATCH] fix: always complete job, no try

---
 apps/api/src/services/queue-worker.ts | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts
index 49137d39..eab79746 100644
--- a/apps/api/src/services/queue-worker.ts
+++ b/apps/api/src/services/queue-worker.ts
@@ -52,11 +52,7 @@ const processJobInternal = async (token: string, job: Job) => {
     const result = await processJob(job, token);
     const jobState = await job.getState();
     if (jobState !== "completed" && jobState !== "failed") {
-      try{
-        await job.moveToCompleted(result.docs, token, false); //3rd arg fetchNext
-      }catch(e){
-        // console.log("Job already completed, error:", e);
-      }
+      await job.moveToCompleted(result.docs, token, false);
     }
   } catch (error) {
     console.log("Job failed, error:", error);