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