@bull-board/api
Advanced tools
Comparing version
@@ -5,8 +5,9 @@ "use strict"; | ||
async function pauseAll(req) { | ||
req.queues.forEach(async (queue) => { | ||
const relevantQueues = req.queues.values().filter((queue) => !queue.readOnlyMode); | ||
for (const queue of relevantQueues) { | ||
const isPaused = await queue.isPaused(); | ||
if (!isPaused) { | ||
queue.pause(); | ||
await queue.pause(); | ||
} | ||
}); | ||
} | ||
return { status: 200, body: { message: 'All queues paused' } }; | ||
@@ -13,0 +14,0 @@ } |
@@ -5,3 +5,4 @@ "use strict"; | ||
async function resumeAll(req) { | ||
req.queues.forEach(async (queue) => { | ||
const relevantQueues = req.queues.values().filter((queue) => !queue.readOnlyMode); | ||
for (const queue of relevantQueues) { | ||
const isPaused = await queue.isPaused(); | ||
@@ -11,3 +12,3 @@ if (isPaused) { | ||
} | ||
}); | ||
} | ||
return { status: 200, body: { message: 'All queues resumed' } }; | ||
@@ -14,0 +15,0 @@ } |
{ | ||
"name": "@bull-board/api", | ||
"version": "6.7.7", | ||
"version": "6.7.8", | ||
"description": "A Dashboard server API built on top of bull or bullmq.", | ||
@@ -42,3 +42,3 @@ "keywords": [ | ||
"peerDependencies": { | ||
"@bull-board/ui": "6.7.7" | ||
"@bull-board/ui": "6.7.8" | ||
}, | ||
@@ -45,0 +45,0 @@ "publishConfig": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
70486
0.52%1147
0.17%