diff --git a/apps/api/src/index.ts b/apps/api/src/index.ts index 818cc5d0..060f6754 100644 --- a/apps/api/src/index.ts +++ b/apps/api/src/index.ts @@ -141,10 +141,14 @@ if (cluster.isMaster) { console.log(" Removing", jobs.length, "jobs..."); await Promise.all(jobs.map(async x => { - await wsq.client.del(await x.lockKey()); - await x.takeLock(); - await x.moveToFailed({ message: "interrupted" }); - await x.remove(); + try { + await wsq.client.del(await x.lockKey()); + await x.takeLock(); + 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...");