From 2e324047bee19fcc3d396265a87aec550396cbef Mon Sep 17 00:00:00 2001
From: Eric Allam <eallam@icloud.com>
Date: Thu, 21 Aug 2025 14:03:23 +0100
Subject: [PATCH] fix(runengine): remove dev worker queues from metrics

---
 internal-packages/run-engine/src/engine/index.ts | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/internal-packages/run-engine/src/engine/index.ts b/internal-packages/run-engine/src/engine/index.ts
index f71c62dcd3..6ee122c418 100644
--- a/internal-packages/run-engine/src/engine/index.ts
+++ b/internal-packages/run-engine/src/engine/index.ts
@@ -565,6 +565,7 @@ export class RunEngine {
     workerId,
     runnerId,
     tx,
+    skipObserving,
   }: {
     consumerId: string;
     workerQueue: string;
@@ -572,9 +573,12 @@ export class RunEngine {
     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,
     });
   }