Render retrying-activity and claim-failed ages on the Waterline dashboard

Surface activities.max_retrying_age_ms / oldest_retrying_started_at on
the Activity attempts panel and tasks.max_claim_failed_age_ms /
oldest_claim_failed_at on the Claim failed runs card so operators can
read transport-failure age and retrying-activity age directly from the
dashboard alongside the existing lease-expired, ready-due, dispatch-
overdue, and compatibility-blocked age indicators.

Author: durable-workflow-ops

resources/js/screens/dashboard.vue

@@ -331,6 +331,12 @@
                             <div class="wl-operator-metric">
                                 <div class="wl-operator-metric__label">Claim failed runs</div>
                                 <div class="wl-operator-metric__value">{{ operatorMetricLabel('backlog', 'claim_failed_runs') }}</div>
+                                <div v-if="operatorClaimFailedAgeAvailable()" class="wl-operator-metric__meta">
+                                    oldest claim {{ operatorDurationMetricLabel('tasks', 'max_claim_failed_age_ms') }} failed
+                                    <template v-if="operatorClaimFailedOldestAt()">
+                                        (since {{ operatorClaimFailedOldestAt() }})
+                                    </template>
+                                </div>
                             </div>
                             <div class="wl-operator-metric">
                                 <div class="wl-operator-metric__label">Compatibility blocked</div>
@@ -383,6 +389,12 @@
                                 {{ operatorMetricLabel('activities', 'failed_attempts') }} failed attempts,
                                 max {{ operatorMetricLabel('activities', 'max_attempt_count') }} attempts.
                             </p>
+                            <p v-if="operatorRetryingActivityAgeAvailable()">
+                                Oldest retrying activity {{ operatorDurationMetricLabel('activities', 'max_retrying_age_ms') }} behind
+                                <template v-if="operatorRetryingActivityOldestStartedAt()">
+                                    (since {{ operatorRetryingActivityOldestStartedAt() }})
+                                </template>.
+                            </p>
                         </section>
 
                         <section class="wl-operator-section">
@@ -1238,6 +1250,42 @@ export default {
             return runs.oldest_wait_started_at || null;
         },
 
+        operatorRetryingActivityAgeAvailable() {
+            const activities = (this.operatorMetrics && this.operatorMetrics.activities) || {};
+
+            if (activities.max_retrying_age_ms === undefined
+                || activities.max_retrying_age_ms === null) {
+                return false;
+            }
+
+            return Number(activities.retrying || 0) > 0
+                || Number(activities.max_retrying_age_ms || 0) > 0;
+        },
+
+        operatorRetryingActivityOldestStartedAt() {
+            const activities = (this.operatorMetrics && this.operatorMetrics.activities) || {};
+
+            return activities.oldest_retrying_started_at || null;
+        },
+
+        operatorClaimFailedAgeAvailable() {
+            const tasks = (this.operatorMetrics && this.operatorMetrics.tasks) || {};
+
+            if (tasks.max_claim_failed_age_ms === undefined
+                || tasks.max_claim_failed_age_ms === null) {
+                return false;
+            }
+
+            return Number(tasks.claim_failed || 0) > 0
+                || Number(tasks.max_claim_failed_age_ms || 0) > 0;
+        },
+
+        operatorClaimFailedOldestAt() {
+            const tasks = (this.operatorMetrics && this.operatorMetrics.tasks) || {};
+
+            return tasks.oldest_claim_failed_at || null;
+        },
+
         operatorSchedulesAvailable() {
             const schedules = this.operatorMetrics && this.operatorMetrics.schedules;
 

tests/Feature/V2DashboardStatsControllerTest.php

@@ -831,6 +831,64 @@ public function testIndexExposesRunWaitAge(): void
         );
     }
 
+    public function testIndexExposesRetryingActivityAge(): void
+    {
+        config()->set('waterline.engine_source', 'v2');
+
+        $response = $this->get('/waterline/api/stats')->assertStatus(200);
+
+        $activities = $response->json('operator_metrics.activities');
+
+        if (! is_array($activities)
+            || ! array_key_exists('max_retrying_age_ms', $activities)
+            || ! array_key_exists('oldest_retrying_started_at', $activities)) {
+            $this->markTestSkipped(
+                'Vendored workflow package predates the retrying-activity age rollout-safety '
+                . 'contract (operator_metrics.activities.{oldest_retrying_started_at,max_retrying_age_ms}).',
+            );
+        }
+
+        $this->assertTrue(
+            $activities['oldest_retrying_started_at'] === null
+                || is_string($activities['oldest_retrying_started_at']),
+            'operator_metrics.activities.oldest_retrying_started_at must be null or ISO-8601 string',
+        );
+        $this->assertTrue(
+            $activities['max_retrying_age_ms'] === null
+                || is_int($activities['max_retrying_age_ms']),
+            'operator_metrics.activities.max_retrying_age_ms must be null or integer milliseconds',
+        );
+    }
+
+    public function testIndexExposesClaimFailedAge(): void
+    {
+        config()->set('waterline.engine_source', 'v2');
+
+        $response = $this->get('/waterline/api/stats')->assertStatus(200);
+
+        $tasks = $response->json('operator_metrics.tasks');
+
+        if (! is_array($tasks)
+            || ! array_key_exists('max_claim_failed_age_ms', $tasks)
+            || ! array_key_exists('oldest_claim_failed_at', $tasks)) {
+            $this->markTestSkipped(
+                'Vendored workflow package predates the claim-failed age rollout-safety '
+                . 'contract (operator_metrics.tasks.{oldest_claim_failed_at,max_claim_failed_age_ms}).',
+            );
+        }
+
+        $this->assertTrue(
+            $tasks['oldest_claim_failed_at'] === null
+                || is_string($tasks['oldest_claim_failed_at']),
+            'operator_metrics.tasks.oldest_claim_failed_at must be null or ISO-8601 string',
+        );
+        $this->assertTrue(
+            $tasks['max_claim_failed_age_ms'] === null
+                || is_int($tasks['max_claim_failed_age_ms']),
+            'operator_metrics.tasks.max_claim_failed_age_ms must be null or integer milliseconds',
+        );
+    }
+
     public function testIndexExposesMatchingRole(): void
     {
         config()->set('waterline.engine_source', 'v2');