dahboard.py amelioration for better visibility

Author: benzekrimaha

monitoring/lifecycle/dashboard.py

@@ -768,6 +768,7 @@ def color_override(name, color):
     dataSource="${DS_PROMETHEUS}",
     fillOpacity=20,
     lineInterpolation="smooth",
+    decimals=0,
     targets=[
         Target(
             expr=Metrics.SCAN_COUNT(type='bucket'),
@@ -786,26 +787,33 @@ def color_override(name, color):
 
 bucket_processor_scan_progress = TimeSeries(
     title="Bucket Processor Scan Progress",
-    description="Shows whether each bucket processor is actively "
-        "processing a scan. Non-zero = scan in progress (value is "
-        "the scan start timestamp). When all pods reset to 0, the "
-        "end-to-end scan is complete.",
+    description="Shows how long each bucket processor has been working "
+        "on the current scan. Drops to 0 / disappears when idle.",
     dataSource="${DS_PROMETHEUS}",
     lineInterpolation="smooth",
+    unit=UNITS.SECONDS,
     targets=[
         Target(
-            expr=Metrics.BUCKET_PROCESSOR_SCAN_START_TIME() + ' > 0',
+            expr='(time() * 1000 - '
+                + Metrics.BUCKET_PROCESSOR_SCAN_START_TIME()
+                + ') / 1000 > 0',
             legendFormat='{{pod}}',
         ),
     ],
 )
 
 bucket_processor_buckets = TimeSeries(
     title="Bucket Processor Lifecycle Buckets",
-    description="Number of lifecycle-enabled buckets processed by "
-        "each bucket processor during the current scan.",
+    description="Running count of lifecycle-enabled bucket tasks "
+        "processed by each bucket processor pod since it last "
+        "detected a new scan. Resets when the pod receives the "
+        "first message of a new conductor scan. As Kafka "
+        "distributes messages across pods, not every pod sees "
+        "every scan boundary, so values may accumulate across "
+        "multiple scans.",
     dataSource="${DS_PROMETHEUS}",
     lineInterpolation="smooth",
+    decimals=0,
     targets=[
         Target(
             expr=Metrics.BUCKET_PROCESSOR_BUCKETS_COUNT(),