From f395c5b0084fac9ba068245b4669e9e08c7d33f5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= Date: Tue, 26 Nov 2024 16:25:48 +0100 Subject: [PATCH] fix(crawl): failed behaviour --- apps/api/src/services/queue-worker.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts index c75acd32..3d5b3e0e 100644 --- a/apps/api/src/services/queue-worker.ts +++ b/apps/api/src/services/queue-worker.ts @@ -404,9 +404,9 @@ async function processJob(job: Job & { id: string }, token: string) { const jobIDs = await getCrawlJobs(job.data.crawl_id); const jobs = (await getJobs(jobIDs)).sort((a, b) => a.timestamp - b.timestamp); - const jobStatuses = await Promise.all(jobs.map((x) => x.getState())); + // const jobStatuses = await Promise.all(jobs.map((x) => x.getState())); const jobStatus = - sc.cancelled || jobStatuses.some((x) => x === "failed") + sc.cancelled // || jobStatuses.some((x) => x === "failed") ? "failed" : "completed";