From 532788862a3168bed26646f0978d0b37ce70389f Mon Sep 17 00:00:00 2001 From: tdurieux Date: Tue, 4 Oct 2022 09:35:36 +0200 Subject: [PATCH] fix: fix retry of non failing job --- src/routes/admin.ts | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/src/routes/admin.ts b/src/routes/admin.ts index a31dbed..af2d3e9 100644 --- a/src/routes/admin.ts +++ b/src/routes/admin.ts @@ -44,8 +44,17 @@ router.post("/queue/:name/:repo_id", async (req, res) => { if (!job) { return res.status(404).json({ error: "job_not_found" }); } - await job.retry(); - res.send("ok"); + try { + await job.retry(); + res.send("ok"); + } catch (error) { + try { + await job.remove(); + queue.add(job.name, job.data, job.opts); + } catch (error) { + res.status(500).send("error_retrying_job"); + } + } }); router.delete("/queue/:name/:repo_id", async (req, res) => {