Surface activity timeout-overdue age on dw system:operator-metrics

Renders the workflow-v2 activity timeout-overdue rollup pinned by the
Phase 6 rollout-safety contract on
`operator_metrics.activities.{timeout_overdue,oldest_timeout_overdue_at,max_timeout_overdue_age_ms}`
so HTTP-only operators can read the worst-case stuck-activity
duplicate-risk age (the activity-path counterpart of
`tasks.lease_expired` — open Pending or Running activity executions
whose `schedule_deadline_at`, `close_deadline_at`,
`schedule_to_close_deadline_at`, or `heartbeat_deadline_at` has
passed and is still waiting for the timeout sweep) directly from
`dw system:operator-metrics` without walking
`activity_executions` themselves.

`OperatorMetricsCommand::renderActivities()` now emits three new rows
right after the existing "Oldest retrying started at" row and before
"Failed attempts":

Timeout overdue:      <count>
Oldest timeout-overdue age: <ms> ms
Oldest timeout-overdue at:  <ISO>

Each row degrades gracefully when the snapshot predates the contract:
the renderer omits the row when its key is absent and the existing
retrying-age and failed-attempts rendering still surfaces the rest of
the activity-path coordination health.

Pins `activities.timeout_overdue`, `activities.oldest_timeout_overdue_at`,
and `activities.max_timeout_overdue_age_ms` on
`schemas/output/operator-metrics.schema.json` next to the existing
retrying-age keys, and adds
`test_operator_metrics_schema_pins_activities_timeout_overdue_keys` and
`test_operator_metrics_command_omits_activities_timeout_overdue_when_snapshot_predates_contract`
plus assertions on the existing render smoke test to guard the schema
declaration, the renderer, and the renderer fallback.

Author: durable-workflow-ops

schemas/output/operator-metrics.schema.json

@@ -125,6 +125,9 @@
             "retrying": { "type": ["integer", "null"] },
             "oldest_retrying_started_at": { "type": ["string", "null"] },
             "max_retrying_age_ms": { "type": ["integer", "null"] },
+            "timeout_overdue": { "type": ["integer", "null"] },
+            "oldest_timeout_overdue_at": { "type": ["string", "null"] },
+            "max_timeout_overdue_age_ms": { "type": ["integer", "null"] },
             "failed_attempts": { "type": ["integer", "null"] },
             "max_attempt_count": { "type": ["integer", "null"] }
           },

src/Commands/SystemCommand/OperatorMetricsCommand.php

@@ -435,6 +435,21 @@ private function renderActivities(OutputInterface $output, array $activities): v
         if (is_string($activities['oldest_retrying_started_at'] ?? null)) {
             $output->writeln(sprintf('  Oldest retrying started at: %s', $activities['oldest_retrying_started_at']));
         }
+        if (array_key_exists('timeout_overdue', $activities)) {
+            $output->writeln(sprintf(
+                '  Timeout overdue:      %d',
+                (int) ($activities['timeout_overdue'] ?? 0),
+            ));
+        }
+        if (array_key_exists('max_timeout_overdue_age_ms', $activities)) {
+            $output->writeln(sprintf(
+                '  Oldest timeout-overdue age: %d ms',
+                (int) ($activities['max_timeout_overdue_age_ms'] ?? 0),
+            ));
+        }
+        if (is_string($activities['oldest_timeout_overdue_at'] ?? null)) {
+            $output->writeln(sprintf('  Oldest timeout-overdue at:  %s', $activities['oldest_timeout_overdue_at']));
+        }
         $output->writeln(sprintf(
             '  Failed attempts:      %d (max attempts on a single execution: %d)',
             (int) ($activities['failed_attempts'] ?? 0),

tests/Commands/SystemCommandTest.php

@@ -572,6 +572,9 @@ public function test_operator_metrics_command_renders_rollout_safety_signals():
         self::assertStringContainsString('Open 12 (pending 8, running 4), retrying 3', $display);
         self::assertStringContainsString('Oldest retrying age:  270000 ms', $display);
         self::assertStringContainsString('Oldest retrying started at: 2026-04-24T11:25:30Z', $display);
+        self::assertStringContainsString('Timeout overdue:      2', $display);
+        self::assertStringContainsString('Oldest timeout-overdue age: 345000 ms', $display);
+        self::assertStringContainsString('Oldest timeout-overdue at:  2026-04-24T11:24:15Z', $display);
         self::assertStringContainsString('Failed attempts:      7 (max attempts on a single execution: 5)', $display);
 
         self::assertStringContainsString('Redispatch after:     120s', $display);
@@ -947,6 +950,45 @@ public function test_operator_metrics_command_omits_activities_block_when_payloa
         self::assertStringNotContainsString('Oldest retrying age', $display);
     }
 
+    public function test_operator_metrics_schema_pins_activities_timeout_overdue_keys(): void
+    {
+        $schema = json_decode(
+            (string) file_get_contents(__DIR__.'/../../schemas/output/operator-metrics.schema.json'),
+            true,
+            flags: JSON_THROW_ON_ERROR,
+        );
+
+        $activities = $schema['properties']['operator_metrics']['properties']['activities']['properties'];
+
+        self::assertSame(['integer', 'null'], $activities['timeout_overdue']['type']);
+        self::assertSame(['string', 'null'], $activities['oldest_timeout_overdue_at']['type']);
+        self::assertSame(['integer', 'null'], $activities['max_timeout_overdue_age_ms']['type']);
+    }
+
+    public function test_operator_metrics_command_omits_activities_timeout_overdue_when_snapshot_predates_contract(): void
+    {
+        $payload = self::operatorMetricsPayload();
+        unset(
+            $payload['operator_metrics']['activities']['timeout_overdue'],
+            $payload['operator_metrics']['activities']['oldest_timeout_overdue_at'],
+            $payload['operator_metrics']['activities']['max_timeout_overdue_age_ms'],
+        );
+
+        $command = new OperatorMetricsCommand();
+        $command->setServerClient(new SystemFakeClient($payload));
+
+        $tester = new CommandTester($command);
+        self::assertSame(Command::SUCCESS, $tester->execute([]));
+
+        $display = $tester->getDisplay();
+
+        self::assertStringNotContainsString('Timeout overdue:', $display);
+        self::assertStringNotContainsString('Oldest timeout-overdue age', $display);
+        self::assertStringNotContainsString('Oldest timeout-overdue at', $display);
+        self::assertStringContainsString('Open 12 (pending 8, running 4), retrying 3', $display);
+        self::assertStringContainsString('Failed attempts:      7', $display);
+    }
+
     public function test_operator_metrics_command_renders_dedicated_matching_role_shape(): void
     {
         $payload = self::operatorMetricsPayload();
@@ -1090,6 +1132,9 @@ private static function operatorMetricsPayload(): array
                     'retrying' => 3,
                     'oldest_retrying_started_at' => '2026-04-24T11:25:30Z',
                     'max_retrying_age_ms' => 270000,
+                    'timeout_overdue' => 2,
+                    'oldest_timeout_overdue_at' => '2026-04-24T11:24:15Z',
+                    'max_timeout_overdue_age_ms' => 345000,
                     'failed_attempts' => 7,
                     'max_attempt_count' => 5,
                 ],