Show backlog flow rates on the Waterline dashboard

Author: durable-workflow-ops

public/app.js

@@ -1,5 +1,5 @@
 {
-    "/app.js": "/app.js?id=ab23f48b8c63bef65e4f9fbbc3543cf4",
+    "/app.js": "/app.js?id=aa9ed769564fbcb973698c985e5b8c9e",
     "/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

@@ -300,6 +300,10 @@
                                     {{ operatorMetricLabel('backlog', 'delayed_tasks') }} delayed,
                                     {{ operatorMetricLabel('backlog', 'leased_tasks') }} leased
                                 </div>
+                                <div class="wl-operator-metric__meta">
+                                    {{ operatorMetricLabel('backlog', 'tasks_added_last_minute') }} added last minute,
+                                    {{ operatorMetricLabel('backlog', 'tasks_dispatched_last_minute') }} dispatched last minute
+                                </div>
                                 <div v-if="operatorReadyDueAgeAvailable()" class="wl-operator-metric__meta">
                                     oldest ready {{ operatorDurationMetricLabel('tasks', 'max_ready_due_age_ms') }} waiting
                                     <template v-if="operatorReadyDueOldestAt()">

resources/js/screens/dashboard.vue

@@ -454,6 +454,8 @@ public function testIndexIncludesV2OperatorMetrics(): void
             ->assertJsonPath('operator_metrics.tasks.lease_expired', 0)
             ->assertJsonPath('operator_metrics.tasks.unhealthy', 1)
             ->assertJsonPath('operator_metrics.backlog.runnable_tasks', 2)
+            ->assertJsonPath('operator_metrics.backlog.tasks_added_last_minute', 2)
+            ->assertJsonPath('operator_metrics.backlog.tasks_dispatched_last_minute', 0)
             ->assertJsonPath('operator_metrics.backlog.retrying_activities', 1)
             ->assertJsonPath('operator_metrics.backlog.repair_needed_runs', 1)
             ->assertJsonPath('operator_metrics.backlog.claim_failed_runs', 1)
@@ -761,6 +763,29 @@ public function testIndexExposesCompatibilityBlockedAge(): void
         );
     }
 
+    public function testIndexExposesBacklogFlowRates(): void
+    {
+        config()->set('waterline.engine_source', 'v2');
+
+        $response = $this->get('/waterline/api/stats')->assertStatus(200);
+
+        $backlog = $response->json('operator_metrics.backlog');
+
+        $this->assertIsArray($backlog);
+
+        foreach (['tasks_added_last_minute', 'tasks_dispatched_last_minute'] as $key) {
+            $this->assertArrayHasKey(
+                $key,
+                $backlog,
+                sprintf('operator_metrics.backlog.%s must be present in the dashboard payload', $key),
+            );
+            $this->assertIsInt(
+                $backlog[$key],
+                sprintf('operator_metrics.backlog.%s must be an integer count', $key),
+            );
+        }
+    }
+
     public function testIndexExposesStuckLeaseAge(): void
     {
         config()->set('waterline.engine_source', 'v2');