Protect against doWork getting called mulitple times per consumer

triggerdotdev · May 15, 2024 · f24b5b7 · f24b5b7
1 parent cb81d6c
commit f24b5b7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/apps/webapp/app/v3/marqs/devQueueConsumer.server.ts b/apps/webapp/app/v3/marqs/devQueueConsumer.server.ts
@@ -90,6 +90,10 @@ export class DevQueueConsumer {
       return;
     }
 
+    if (this._backgroundWorkers.has(backgroundWorker.id)) {
+      return;
+    }
+
     this._backgroundWorkers.set(backgroundWorker.id, backgroundWorker);
 
     logger.debug("Registered background worker", { backgroundWorker: backgroundWorker.id });
@@ -271,10 +275,10 @@ export class DevQueueConsumer {
       return;
     }
 
+    this._enabled = true;
     // Create the session
     await createNewSession(this.env, this._options.ipAddress ?? "unknown");
 
-    this._enabled = true;
     this._perTraceCountdown = this._options.maximumItemsPerTrace;
     this._lastNewTrace = new Date();
     this._taskFailures = 0;