diff --git a/server/src/worker.ts b/server/src/worker.ts
index 5bf388f2..8a2e5e97 100644
--- a/server/src/worker.ts
+++ b/server/src/worker.ts
@@ -32,18 +32,10 @@ const worker = new Worker('workflow', async job => {
 
 worker.on('completed', async (job: any) => {
     logger.log(`info`, `Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`);
-
-    await worker.close();
-    await workflowQueue.close();
-    logger.log(`info`, `Worker and queue have been closed.`);
 });
 
 worker.on('failed', async (job: any, err) => {
     logger.log(`error`, `Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err);
-
-    await worker.close();
-    await workflowQueue.close();
-    logger.log(`info`, `Worker and queue have been closed after failure.`);
 });
 
 async function jobCounts() {