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