Revert "First draft of worker pausing"

This reverts commit 6aa3298

Author: rpanic

packages/deployment/src/queue/BullQueue.ts

@@ -22,10 +22,6 @@ export interface BullQueueConfig {
   retryAttempts?: number;
 }
 
-interface BullWorker extends Closeable {
-  get worker(): Worker;
-}
-
 /**
  * TaskQueue implementation for BullMQ
  */
@@ -36,10 +32,6 @@ export class BullQueue
 {
   private activePromise?: Promise<void>;
 
-  private activeWorkers: Record<string, BullWorker> = {};
-
-  private activeJobs = 0;
-
   public createWorker(
     name: string,
     executor: (data: TaskPayload) => Promise<TaskPayload>,
@@ -52,7 +44,6 @@ export class BullQueue
         // This is by far not optimal - since it still picks up 1 task per queue but waits until
         // computing them, so that leads to bad performance over multiple workers.
         // For that we need to restructure tasks to be flowing through a single queue however
-        this.activeJobs += 1;
 
         // TODO Use worker.pause()
         while (this.activePromise !== undefined) {
@@ -65,27 +56,10 @@ export class BullQueue
         });
         this.activePromise = promise;
 
-        // Pause all other workers
-        const workersToPause = Object.entries(this.activeWorkers).filter(
-          ([key]) => key !== name
-        );
-        await Promise.all(
-          workersToPause.map(([, workerToPause]) =>
-            workerToPause.worker.pause(true)
-          )
-        );
-
         const result = await executor(job.data);
         this.activePromise = undefined;
         void resOutside();
 
-        this.activeJobs -= 1;
-        if (this.activeJobs === 0) {
-          Object.entries(this.activeWorkers).forEach(([, resumingWorker]) =>
-            resumingWorker.worker.resume()
-          );
-        }
-
         return result;
       },
       {
@@ -104,16 +78,11 @@ export class BullQueue
       log.error(error);
     });
 
-    const instantiatedWorker = {
+    return {
       async close() {
         await worker.close();
       },
-      get worker() {
-        return worker;
-      },
     };
-    this.activeWorkers[name] = instantiatedWorker;
-    return instantiatedWorker;
   }
 
   public async getQueue(queueName: string): Promise<InstantiatedQueue> {