fix(runengine): remove dev worker queues from metrics

Author: ericallam

internal-packages/run-engine/src/engine/index.ts

@@ -565,16 +565,20 @@ export class RunEngine {
     workerId,
     runnerId,
     tx,
+    skipObserving,
   }: {
     consumerId: string;
     workerQueue: string;
     backgroundWorkerId?: string;
     workerId?: string;
     runnerId?: string;
     tx?: PrismaClientOrTransaction;
+    skipObserving?: boolean;
   }): Promise<DequeuedMessage[]> {
-    // We only do this with "prod" worker queues because we don't want to observe dev (e.g. environment) worker queues
-    this.runQueue.registerObservableWorkerQueue(workerQueue);
+    if (!skipObserving) {
+      // We only do this with "prod" worker queues because we don't want to observe dev (e.g. environment) worker queues
+      this.runQueue.registerObservableWorkerQueue(workerQueue);
+    }
 
     const dequeuedMessage = await this.dequeueSystem.dequeueFromWorkerQueue({
       consumerId,
@@ -614,6 +618,7 @@ export class RunEngine {
       workerId,
       runnerId,
       tx,
+      skipObserving: true,
     });
   }