fix: abortsignal pre-check

This commit is contained in:
Gergő Móricz 2025-05-30 17:36:14 +02:00
parent 42c8adf9e5
commit 656c769f73

View File

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