Fix streaks graph

Tom-Newton · Mar 28, 2024 · 4f38d3f · 4f38d3f
1 parent 80f509f
commit 4f38d3f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/stats/flytepropeller.dashboard.py b/stats/flytepropeller.dashboard.py
@@ -112,13 +112,13 @@ def error_breakdown() -> Graph:
         )
 
     @staticmethod
-    def streak_length() -> Graph:
+    def streak_rate() -> Graph:
         return Graph(
-            title="Avg streak length",
+            title="Streak rate",
             dataSource=DATASOURCE,
             targets=[
                 Target(
-                    expr="avg(flyte:propeller:all:round:streak_length_unlabeled)",
+                    expr="sum(rate(flyte:propeller:all:round:streak_length_unlabeled[5m]))",
                     refId="A",
                 ),
             ],
@@ -824,7 +824,7 @@ def core_metrics(interval: int, collapse: bool) -> Row:
                 FlytePropeller.round_rates(),
                 FlytePropeller.error_breakdown(),
                 FlytePropeller.skipped_rounds(),
-                FlytePropeller.streak_length(),
+                FlytePropeller.streak_rate(),
                 FlytePropeller.plugin_success_vs_failures(),
                 FlytePropeller.round_latency(),
                 FlytePropeller.round_latency_per_wf(),