Feature - record / persist only failed tasks

docs/config.rst

@@ -540,3 +540,14 @@ Default: None
 Sets the URI to which an OAuth 2.0 server redirects the user after successful authentication and authorization.
 
 `oauth2_redirect_uri` option should be used with :ref:`auth`, :ref:`auth_provider`, :ref:`oauth2_key` and :ref:`oauth2_secret` options.
+
+.. _persist_only_failed_tasks:
+
+persist_only_failed_tasks
+~~~~~~~~~~~~~~~~~~~
+
+Default: False
+
+Config to persist only failed tasks
+
+.. Note:: When persist_only_failed_tasks mode is enabled, Flower only show failed tasks, but still count number of other tasks.

flower/events.py

@@ -96,6 +96,11 @@ def event(self, event):
             if event_type in ['task-succeeded', 'task-failed'] and not task.eta and task_started and task_received:
                 self.metrics.prefetch_time.labels(worker_name, task_name).set(0)
 
+            if options.persist_only_failed_tasks:
+                if event_type in ['task-succeeded', 'task-revoked']:
+                    del self.tasks[task_id]
+                    self.rebuild_taskheap()
+
         if event_type == 'worker-online':
             self.metrics.worker_online.labels(worker_name).set(1)
 

flower/options.py

@@ -68,6 +68,6 @@
 define("url_prefix", type=str, help="base url prefix")
 define("task_runtime_metric_buckets", type=float, default=Histogram.DEFAULT_BUCKETS,
        multiple=True, help="histogram latency bucket value")
-
+define("persist_only_failed_tasks", type=bool, help="Persist only failed tasks", default=False)
 
 default_options = options