fix operation order

This commit is contained in:
Gergő Móricz 2025-04-04 21:49:54 +02:00
parent 78e54a0457
commit 03f7fb19a1

View File

@ -685,10 +685,10 @@ const workerFun = async (
const delayInSeconds = job.data.crawlerOptions.delay;
const delayInMs = delayInSeconds * 1000;
await new Promise(resolve => setTimeout(resolve, delayInMs));
const nextCrawlJob = await takeCrawlConcurrencyLimitedJob(job.data.crawl_id);
if (nextCrawlJob !== null) {
await new Promise(resolve => setTimeout(resolve, delayInMs));
await pushCrawlConcurrencyLimitActiveJob(job.data.crawl_id, nextCrawlJob.id, 60 * 1000);
await queue.add(