Draining all task queues in BullQueue.start()

Author: Raunaque97

packages/deployment/src/queue/BullQueue.ts

@@ -1,5 +1,5 @@
 import { MetricsTime, Queue, QueueEvents, Worker } from "bullmq";
-import { log, noop } from "@proto-kit/common";
+import { log } from "@proto-kit/common";
 import {
   TaskPayload,
   Closeable,
@@ -102,7 +102,8 @@ export class BullQueue
   }
 
   public async start() {
-    noop();
+    // Drain all queues to clear stale tasks from previous sequencer instances
+    await this.drainAllQueues();
   }
 
   public async close() {

packages/sequencer/src/sequencer/executor/Sequencer.ts

@@ -22,7 +22,6 @@ import { SequencerModule } from "../builder/SequencerModule";
 import { Closeable } from "../builder/Closeable";
 import { ConsoleTracingFactory } from "../../logging/ConsoleTracingFactory";
 import { StartableModule } from "../builder/StartableModule";
-import { TaskQueue } from "../../worker/queue/TaskQueue";
 
 import { Sequenceable } from "./Sequenceable";
 
@@ -86,12 +85,6 @@ export class Sequencer<Modules extends SequencerModulesRecord>
 
     this.useDependencyFactory(MethodIdFactory);
 
-    // Drain all task queues to clear stale tasks from previous sequencer instances
-    if (this.container.isRegistered("TaskQueue")) {
-      const taskQueue = this.container.resolve<TaskQueue>("TaskQueue");
-      await taskQueue.drainAllQueues();
-    }
-
     // Log startup info
     const moduleClassNames = Object.values(this.definition).map(
       (clazz) => clazz.name