From d036738da05b5d85dbcafdad3508ff4fc1aa44b7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= Date: Thu, 22 Aug 2024 18:04:09 +0200 Subject: [PATCH] fix(bullmq): duplicate redis connection for QueueEvents --- apps/api/src/services/queue-service.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/api/src/services/queue-service.ts b/apps/api/src/services/queue-service.ts index b13489a6..2e6d7562 100644 --- a/apps/api/src/services/queue-service.ts +++ b/apps/api/src/services/queue-service.ts @@ -37,4 +37,4 @@ export function getScrapeQueue() { import { QueueEvents } from 'bullmq'; -export const scrapeQueueEvents = new QueueEvents(scrapeQueueName, { connection: redisConnection }); \ No newline at end of file +export const scrapeQueueEvents = new QueueEvents(scrapeQueueName, { connection: redisConnection.duplicate() }); \ No newline at end of file