Scope worker compatibility metrics to the requested namespace

Author: durable-workflow-ops

src/V2/Support/OperatorMetrics.php

@@ -50,7 +50,7 @@ public static function snapshot(?CarbonInterface $now = null, ?string $namespace
             'command_contracts' => self::commandContractMetrics($namespace),
             'projections' => self::projectionMetrics($now, $namespace),
             'schedules' => self::scheduleMetrics($now, $namespace),
-            'workers' => self::workerMetrics(),
+            'workers' => self::workerMetrics($namespace),
             'backend' => BackendCapabilities::snapshot($now),
             'structural_limits' => StructuralLimits::snapshot(),
             'update_wait' => UpdateWaitPolicy::snapshot(),
@@ -302,10 +302,13 @@ private static function scheduleMetrics(CarbonInterface $now, ?string $namespace
     /**
      * @return array<string, mixed>
      */
-    private static function workerMetrics(): array
+    private static function workerMetrics(?string $namespace): array
     {
         $required = WorkerCompatibility::current();
-        $snapshots = WorkerCompatibilityFleet::details($required);
+        $compatibilityNamespace = $namespace ?? WorkerCompatibilityFleet::scopeNamespace();
+        $snapshots = $compatibilityNamespace === null
+            ? WorkerCompatibilityFleet::details($required)
+            : WorkerCompatibilityFleet::detailsForNamespace($compatibilityNamespace, $required);
         $workerIds = [];
         $supportingWorkerIds = [];
         $fleet = [];
@@ -329,7 +332,7 @@ private static function workerMetrics(): array
         }
 
         return [
-            'compatibility_namespace' => WorkerCompatibilityFleet::scopeNamespace(),
+            'compatibility_namespace' => $compatibilityNamespace,
             'required_compatibility' => $required,
             'active_workers' => count($workerIds),
             'active_worker_scopes' => count($snapshots),

tests/Feature/V2/V2OperatorMetricsTest.php

@@ -65,6 +65,34 @@ public function testWorkerFleetSnapshotFallsBackToCacheWhenHeartbeatTableIsUnava
         $this->assertTrue($snapshot['workers']['fleet'][0]['supports_required']);
     }
 
+    public function testWorkerFleetSnapshotUsesRequestedNamespaceInsteadOfConfiguredCompatibilityNamespace(): void
+    {
+        Carbon::setTestNow('2026-04-09 12:00:00');
+        $this->beforeApplicationDestroyed(static function (): void {
+            Carbon::setTestNow();
+            WorkerCompatibilityFleet::clear();
+        });
+
+        config()
+            ->set('workflows.v2.compatibility.current', 'build-a');
+        config()
+            ->set('workflows.v2.compatibility.namespace', 'shipping');
+
+        WorkerCompatibilityFleet::clear();
+        WorkerCompatibilityFleet::recordForNamespace('billing', ['build-a'], 'redis', 'default', 'worker-billing');
+        WorkerCompatibilityFleet::recordForNamespace('shipping', ['build-a'], 'redis', 'default', 'worker-shipping');
+
+        $snapshot = OperatorMetrics::snapshot(now(), 'billing');
+
+        $this->assertSame('billing', $snapshot['workers']['compatibility_namespace']);
+        $this->assertSame(1, $snapshot['workers']['active_workers']);
+        $this->assertSame(1, $snapshot['workers']['active_worker_scopes']);
+        $this->assertSame(1, $snapshot['workers']['active_workers_supporting_required']);
+        $this->assertCount(1, $snapshot['workers']['fleet']);
+        $this->assertSame('worker-billing', $snapshot['workers']['fleet'][0]['worker_id']);
+        $this->assertSame('billing', $snapshot['workers']['fleet'][0]['namespace']);
+    }
+
     public function testSnapshotSummarizesDurableBacklogRepairCompatibilityAndWorkerFleet(): void
     {
         Carbon::setTestNow('2026-04-09 12:00:00');