Iyeoluwads/firecrawl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(queue-worker): bad job lock extension time

Browse Source
This commit is contained in:
Gergo Moricz
2024-08-07 20:24:16 +02:00
parent ab7a35c581
commit 55ec96c23f
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/api/src/services/queue-worker.ts
+2 -1
View File
@@ -33,7 +33,7 @@ const workerStalledCheckInterval =
const jobLockExtendInterval = const jobLockExtendInterval =
Number(process.env.JOB_LOCK_EXTEND_INTERVAL) || 15000; Number(process.env.JOB_LOCK_EXTEND_INTERVAL) || 15000;
const jobLockExtensionTime = const jobLockExtensionTime =
Number(process.env.JOB_LOCK_EXTENSION_TIME) || 15000; Number(process.env.JOB_LOCK_EXTENSION_TIME) || 60000;
const cantAcceptConnectionInterval = const cantAcceptConnectionInterval =
Number(process.env.CANT_ACCEPT_CONNECTION_INTERVAL) || 2000; Number(process.env.CANT_ACCEPT_CONNECTION_INTERVAL) || 2000;
@@ -52,6 +52,7 @@ const processJobInternal = async (token: string, job: Job) => {
try { try {
const result = await processJob(job, token); const result = await processJob(job, token);
const jobState = await job.getState(); const jobState = await job.getState();
console.log("done", job, jobState, result);
if (jobState !== "completed" && jobState !== "failed") { if (jobState !== "completed" && jobState !== "failed") {
await job.moveToCompleted(result.docs, token, false); await job.moveToCompleted(result.docs, token, false);
} }