AI/firecrawl
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/mendableai/firecrawl synced 2025-08-14 18:55:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: try-catch job removal

Browse Source
This commit is contained in:
Gergo Moricz 2024-07-12 16:35:34 +02:00
parent 69d724714f
commit 0d3e09e798
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/api/src/index.ts
View File

@ -141,10 +141,14 @@ if (cluster.isMaster) {
console.log(" Removing", jobs.length, "jobs..."); console.log(" Removing", jobs.length, "jobs...");
await Promise.all(jobs.map(async x => { await Promise.all(jobs.map(async x => {
await wsq.client.del(await x.lockKey()); try {
await x.takeLock(); await wsq.client.del(await x.lockKey());
await x.moveToFailed({ message: "interrupted" }); await x.takeLock();
await x.remove(); await x.moveToFailed({ message: "interrupted" });
await x.remove();
} catch (e) {
console.warn("Failed to remove job", x.id, e);
}
})); }));
console.log(" Re-adding", jobs.length, "jobs..."); console.log(" Re-adding", jobs.length, "jobs...");