From d23296dc614edbaf6a35e19ab795dc32934ca987 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= Date: Thu, 23 Oct 2025 17:55:51 +0200 Subject: [PATCH] fix: crawl finishing --- apps/api/src/services/extract-worker.ts | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/apps/api/src/services/extract-worker.ts b/apps/api/src/services/extract-worker.ts index 03a6ccdaf..57132fbe7 100644 --- a/apps/api/src/services/extract-worker.ts +++ b/apps/api/src/services/extract-worker.ts @@ -253,7 +253,13 @@ const workerFun = async ( } }; -async function processFinishCrawlJobInternal(job: NuQJob, logger: Logger) { +async function processFinishCrawlJobInternal(_job: NuQJob, logger: Logger) { + const job = await crawlFinishedQueue.getJob(_job.id); + + if (!job) { + throw new Error("crawlFinish job disappeared"); + } + if (!job.groupId) { throw new Error("crawlFinish job with no groupId"); }