Render matching-role partition and backpressure metadata

Backfill the frozen matching-role partition and lease-based backpressure fields on Waterline's operator metrics surface when older workflow package versions omit them, so the dashboard can render the extra routing details without waiting for a workflow package bump.

Author: durable-workflow-ops

app/Repositories/Workflow/Infrastructure/V2WorkflowRepository.php

@@ -73,8 +73,8 @@ public function dashboardStats(): array
         $namespace = $this->namespace();
         $now = now();
         $summary = app(OperatorObservabilityRepository::class)->dashboardSummary($now, $namespace);
-        $summary['operator_metrics']['workers'] = $this->scopedWorkerMetrics(
-            $summary['operator_metrics']['workers'] ?? null,
+        $summary['operator_metrics'] = $this->annotateOperatorMetrics(
+            $summary['operator_metrics'] ?? null,
             $namespace,
         );
 
@@ -152,7 +152,27 @@ public function operatorMetrics()
     {
         $namespace = $this->namespace();
         $metrics = app(OperatorObservabilityRepository::class)->metrics(null, $namespace);
+        $metrics = $this->annotateOperatorMetrics($metrics, $namespace);
+
+        return $metrics;
+    }
+
+    /**
+     * Keep Waterline compatible with older workflow alphas that omit
+     * namespace-scoped worker snapshots or the expanded matching-role
+     * routing contract on the operator metrics surface.
+     *
+     * @param mixed $metrics
+     * @return mixed
+     */
+    private function annotateOperatorMetrics(mixed $metrics, ?string $namespace): mixed
+    {
+        if (! is_array($metrics)) {
+            return $metrics;
+        }
+
         $metrics['workers'] = $this->scopedWorkerMetrics($metrics['workers'] ?? null, $namespace);
+        $metrics['matching_role'] = $this->matchingRoleMetrics($metrics['matching_role'] ?? null);
 
         return $metrics;
     }
@@ -209,6 +229,31 @@ private function scopedWorkerMetrics(mixed $workers, ?string $namespace): mixed
         return $workers;
     }
 
+    /**
+     * The task-matching contract freezes the partition primitives and the
+     * lease-based backpressure model even though older workflow alphas did
+     * not yet expose them on OperatorMetrics::snapshot().
+     *
+     * @param mixed $matchingRole
+     * @return mixed
+     */
+    private function matchingRoleMetrics(mixed $matchingRole): mixed
+    {
+        if (! is_array($matchingRole)) {
+            return $matchingRole;
+        }
+
+        if (! array_key_exists('partition_primitives', $matchingRole)) {
+            $matchingRole['partition_primitives'] = ['connection', 'queue', 'compatibility', 'namespace'];
+        }
+
+        if (! array_key_exists('backpressure_model', $matchingRole)) {
+            $matchingRole['backpressure_model'] = 'lease_ownership';
+        }
+
+        return $matchingRole;
+    }
+
     /**
      * @param array<string, mixed> $snapshot
      * @return array<string, mixed>

public/app.js

@@ -1,5 +1,5 @@
 {
-    "/app.js": "/app.js?id=af2b8443ef291871597df9e83087c328",
+    "/app.js": "/app.js?id=ed9bd12b08ad1f7f9c27a64da04c4222",
     "/app-dark.css": "/app-dark.css?id=8b1b08a71c8e9860d0a9030d902c30d0",
     "/app.css": "/app.css?id=4d346e04fa466f5227cee3c313fbea25",
     "/img/favicon.png": "/img/favicon.png?id=7c006241b093796d6abfa3049df93a59",

public/mix-manifest.json

@@ -524,6 +524,10 @@
                                     queue-wake {{ operatorMatchingRoleQueueWakeEnabled() ? 'enabled' : 'disabled' }},
                                     task dispatch <code>{{ operatorMatchingRoleTaskDispatchMode() }}</code>.
                                 </p>
+                                <p v-if="operatorMatchingRoleContractAvailable()">
+                                    Partitions by <code>{{ operatorMatchingRolePartitionPrimitivesLabel() }}</code>,
+                                    backpressure <code>{{ operatorMatchingRoleBackpressureModel() }}</code>.
+                                </p>
                                 <p class="text-muted">
                                     Single-process scope &mdash; read one snapshot per node to see the full deployment.
                                 </p>
@@ -1462,6 +1466,36 @@ export default {
                 : 'unknown';
         },
 
+        operatorMatchingRoleContractAvailable() {
+            const matchingRole = (this.operatorMetrics && this.operatorMetrics.matching_role) || {};
+
+            return this.operatorMatchingRolePartitionPrimitives(matchingRole).length > 0
+                || (typeof matchingRole.backpressure_model === 'string' && matchingRole.backpressure_model !== '');
+        },
+
+        operatorMatchingRolePartitionPrimitives(matchingRole = null) {
+            const snapshot = matchingRole || ((this.operatorMetrics && this.operatorMetrics.matching_role) || {});
+            const primitives = Array.isArray(snapshot.partition_primitives) ? snapshot.partition_primitives : [];
+
+            return primitives.filter((primitive) => typeof primitive === 'string' && primitive !== '');
+        },
+
+        operatorMatchingRolePartitionPrimitivesLabel() {
+            const primitives = this.operatorMatchingRolePartitionPrimitives();
+
+            return primitives.length > 0
+                ? primitives.join(' / ')
+                : 'unknown';
+        },
+
+        operatorMatchingRoleBackpressureModel() {
+            const matchingRole = (this.operatorMetrics && this.operatorMetrics.matching_role) || {};
+
+            return typeof matchingRole.backpressure_model === 'string' && matchingRole.backpressure_model !== ''
+                ? matchingRole.backpressure_model
+                : 'unknown';
+        },
+
         operatorScheduleOldestOverdueAt() {
             const schedules = (this.operatorMetrics && this.operatorMetrics.schedules) || {};
 
@@ -1836,4 +1870,4 @@ export default {
         grid-template-columns: minmax(0, 1fr);
     }
 }
-</style>
+</style>

resources/js/screens/dashboard.vue

@@ -968,6 +968,8 @@ public function testIndexExposesMatchingRole(): void
         $this->assertArrayHasKey('queue_wake_enabled', $matchingRole);
         $this->assertArrayHasKey('shape', $matchingRole);
         $this->assertArrayHasKey('task_dispatch_mode', $matchingRole);
+        $this->assertArrayHasKey('partition_primitives', $matchingRole);
+        $this->assertArrayHasKey('backpressure_model', $matchingRole);
 
         $this->assertIsBool($matchingRole['queue_wake_enabled']);
         $this->assertContains(
@@ -980,6 +982,16 @@ public function testIndexExposesMatchingRole(): void
             ['queue', 'poll'],
             'operator_metrics.matching_role.task_dispatch_mode must be queue or poll',
         );
+        $this->assertSame(
+            ['connection', 'queue', 'compatibility', 'namespace'],
+            $matchingRole['partition_primitives'],
+            'operator_metrics.matching_role.partition_primitives must preserve the frozen queue routing order',
+        );
+        $this->assertSame(
+            'lease_ownership',
+            $matchingRole['backpressure_model'],
+            'operator_metrics.matching_role.backpressure_model must preserve the frozen matching-role backpressure contract',
+        );
     }
 
     public function testIndexExposesUnhealthyAgeRollup(): void