From cdf7bad5b4bc001c739096387f7e078fa043174b Mon Sep 17 00:00:00 2001
From: Gergo Moricz <mo.geryy@gmail.com>
Date: Wed, 7 Aug 2024 15:20:56 +0200
Subject: [PATCH] fix(runWebScraper): don't move to completed

---
 apps/api/src/main/runWebScraper.ts    | 2 +-
 apps/api/src/services/queue-worker.ts | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/api/src/main/runWebScraper.ts b/apps/api/src/main/runWebScraper.ts
index 76665aa2..ba22f28b 100644
--- a/apps/api/src/main/runWebScraper.ts
+++ b/apps/api/src/main/runWebScraper.ts
@@ -131,7 +131,7 @@ const saveJob = async (job: Job, result: any) => {
 
       if (error) throw new Error(error.message);
       try {
-        await job.moveToCompleted(null, false, false);
+        // await job.moveToCompleted(null, false, false);
       } catch (error) {
         // I think the job won't exist here anymore
       }
diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts
index a82f12cd..bddf9300 100644
--- a/apps/api/src/services/queue-worker.ts
+++ b/apps/api/src/services/queue-worker.ts
@@ -68,7 +68,7 @@ async function processJob(job: Job, done) {
     });
     Logger.info(`🐂 Job done ${job.id}`);
     clearInterval(lockInterval);
-    done(null, data);
+    done(null, null);
   } catch (error) {
     Logger.error(`🐂 Job errored ${job.id} - ${error}`);
     if (await getWebScraperQueue().isPaused(false)) {