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();