From d396dac9bd4588b74599ae8b5e87e7997c08f0b9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?rogger=20andr=C3=A9=20valverde=20flores?=
 <rogger.valverde@uni.pe>
Date: Wed, 3 Mar 2021 19:22:16 -0500
Subject: [PATCH] fix(bulkaction): handling retry logic in bulk

---
 public/dashboard.js                | 2 +-
 src/server/views/api/bulkAction.js | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/public/dashboard.js b/public/dashboard.js
index 499b9ef2..03596c7c 100644
--- a/public/dashboard.js
+++ b/public/dashboard.js
@@ -108,7 +108,7 @@ $(document).ready(() => {
 
     let data = {
       queueName,
-      action: 'remove',
+      action,
       jobs: [],
     };
 
diff --git a/src/server/views/api/bulkAction.js b/src/server/views/api/bulkAction.js
index e7548ac0..1b3fdc1a 100644
--- a/src/server/views/api/bulkAction.js
+++ b/src/server/views/api/bulkAction.js
@@ -22,8 +22,10 @@ function bulkAction(action) {
       if (!_.isEmpty(jobs)) {
         const jobsPromises = jobs.map((id) => queue.getJob(decodeURIComponent(id)));
         const fetchedJobs = await Promise.all(jobsPromises);
-
-        const actionPromises = fetchedJobs.map((job) => job[action]());
+        const actionPromises =
+          action === 'retry'
+            ? fetchedJobs.map((job) => Queues.set(queue, job.data, job.name))
+            : fetchedJobs.map((job) => job[action]());
         await Promise.all(actionPromises);
         return res.sendStatus(200);
       }