From 780cda6e4b250f3a1accb312ee2b13826ef18508 Mon Sep 17 00:00:00 2001 From: Hongbo Wu Date: Fri, 19 Jan 2024 20:44:54 +0800 Subject: [PATCH] use worker redis client when connect to the queue in queue-processor --- packages/api/src/queue-processor.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/packages/api/src/queue-processor.ts b/packages/api/src/queue-processor.ts index d835aecc3..283b3b9c0 100644 --- a/packages/api/src/queue-processor.ts +++ b/packages/api/src/queue-processor.ts @@ -61,7 +61,9 @@ const main = async () => { throw '[queue-processor] error redis is not initialized' } - const queue = new Queue(QUEUE_NAME) + const queue = new Queue(QUEUE_NAME, { + connection: workerRedisClient, + }) const worker = new Worker( QUEUE_NAME,