fix(bulkaction): handling retry logic in bulk

bee-queue · Mar 4, 2021 · d396dac · d396dac
1 parent 52c9b80
commit d396dac
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git 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
@@ -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);
       }