From 656c769f73f193657ba45bddb128fbe8469e7896 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= Date: Fri, 30 May 2025 17:36:14 +0200 Subject: [PATCH] fix: abortsignal pre-check --- apps/api/src/services/queue-worker.ts | 3 +++ 1 file changed, 3 insertions(+) diff --git a/apps/api/src/services/queue-worker.ts b/apps/api/src/services/queue-worker.ts index 02d9245c..1a1ffc10 100644 --- a/apps/api/src/services/queue-worker.ts +++ b/apps/api/src/services/queue-worker.ts @@ -1130,6 +1130,9 @@ async function processJob(job: Job & { id: string }, token: string) { logger.info(`🐂 Worker taking job ${job.id}`, { url: job.data.url }); const start = job.data.startTime ?? Date.now(); const remainingTime = job.data.scrapeOptions.timeout ? (job.data.scrapeOptions.timeout - (Date.now() - start)) : undefined; + if (remainingTime !== undefined && remainingTime < 0) { + throw new Error("timeout"); + } const signal = remainingTime ? AbortSignal.timeout(remainingTime) : undefined; const costTracking = new CostTracking();