From 03475e73e8df7de08a2045be1ef8574c585a5d7a Mon Sep 17 00:00:00 2001 From: Patrick Heeney <1407228+patrickheeney@users.noreply.github.com> Date: Thu, 31 Aug 2023 22:52:02 -0700 Subject: [PATCH] chore(bullmq): support prioritized job state (#662) --- src/server/views/dashboard/queueDetails.js | 2 -- src/server/views/helpers/queueHelpers.js | 1 + 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/src/server/views/dashboard/queueDetails.js b/src/server/views/dashboard/queueDetails.js index 079eb4ad..86bf075e 100644 --- a/src/server/views/dashboard/queueDetails.js +++ b/src/server/views/dashboard/queueDetails.js @@ -18,8 +18,6 @@ async function handler(req, res) { if (queue.IS_BEE) { jobCounts = await queue.checkHealth(); delete jobCounts.newestJob; - } else if (queue.IS_BULLMQ) { - jobCounts = await queue.getJobCounts(...QueueHelpers.BULLMQ_STATES); } else { jobCounts = await queue.getJobCounts(); } diff --git a/src/server/views/helpers/queueHelpers.js b/src/server/views/helpers/queueHelpers.js index 2e0f2e00..75b0e3bd 100644 --- a/src/server/views/helpers/queueHelpers.js +++ b/src/server/views/helpers/queueHelpers.js @@ -81,6 +81,7 @@ const Helpers = { */ BULLMQ_STATES: [ 'waiting', + 'prioritized', 'active', 'completed', 'failed',