From 273e593a930227678918eaeec7233db4ccc9c048 Mon Sep 17 00:00:00 2001 From: Jackson Harper Date: Fri, 12 Jan 2024 13:18:04 +0800 Subject: [PATCH] Fix init of queue workers --- pkg/bull-queue-admin/index.js | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/pkg/bull-queue-admin/index.js b/pkg/bull-queue-admin/index.js index 016bc26c3..ca32a2bc4 100644 --- a/pkg/bull-queue-admin/index.js +++ b/pkg/bull-queue-admin/index.js @@ -57,12 +57,10 @@ const run = async () => { maxRetriesPerRequest: null, } } - const createQueueMQ = (name) => - new QueueMQ(secrets.REDIS_URL, { - connection: redisOptions, - }) - const rssRefreshFeed = createQueueMQ('rssRefreshFeed') + const rssRefreshFeed = createQueueMQ('rssRefreshFeed', { + connection: redisOptions, + }) const serverAdapter = new ExpressAdapter() serverAdapter.setBasePath('/ui')