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