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,