From 4ef3e87d57a8e9ec1b203fe502f230c0c5863f6f Mon Sep 17 00:00:00 2001 From: Abhinav Gautam Date: Tue, 8 Oct 2024 21:10:02 +0530 Subject: [PATCH] fix processorfile --- src/utils/queue-client.ts | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/utils/queue-client.ts b/src/utils/queue-client.ts index 230f360..6df7814 100644 --- a/src/utils/queue-client.ts +++ b/src/utils/queue-client.ts @@ -37,10 +37,7 @@ checkQueueHealth(queue).then(jobCounts => { const processorFile = path.join(__dirname, 'sandbox_worker.js'); function createSandboxedWorker() { - return new Worker('pdfQueue', processorFile,{ - connection:bullConnection.connection, - concurrency:parseInt(workerConcurrency) - }); + return new Worker('pdfQueue', processorFile,{...bullConnection,concurrency:parseInt(workerConcurrency)}); } // Start multiple sandboxed workers