only send the aggregate metric, instead of per worker

headway · Apr 10, 2023 · d1f6b0c · d1f6b0c · zemek · Apr 10, 2023
1 parent a4fc7c9
commit d1f6b0c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flower/events.py b/flower/events.py
@@ -36,7 +36,7 @@ def get_prometheus_metrics():
 class PrometheusMetrics(object):
 
     def __init__(self):
-        self.events = PrometheusCounter('flower_events_total', "Number of events", ['worker', 'type', 'task'])
+        self.events = PrometheusCounter('flower_events_total', "Number of events", ['type', 'task'])
 
         self.runtime = Histogram(
             'flower_task_runtime_seconds',
@@ -85,7 +85,8 @@ def event(self, event):
             task_name = event.get('name', '')
             if not task_name and task_id in self.tasks:
                 task_name = task.name or ''
-            self.metrics.events.labels(worker_name, event_type, task_name).inc()
+
+            self.metrics.events.labels(event_type, task_name).inc()
 
             runtime = event.get('runtime', 0)
             if runtime: