Don't include tasks with no start date

qiuwei · Mar 11, 2020 · 078a151 · 078a151
1 parent 43862bf
commit 078a151
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/airflow_prometheus_exporter/prometheus_exporter.py b/airflow_prometheus_exporter/prometheus_exporter.py
@@ -120,6 +120,10 @@ def get_dag_duration_info():
                     == dag_start_dt_query.c.execution_date,
                 ),
             )
+            .filter(
+                TaskInstance.start_date.isnot(None),
+                TaskInstance.end_date.isnot(None),
+            )
             .all()
         )
 
@@ -479,7 +483,6 @@ def collect(self):
 if RBAC:
     from flask_appbuilder import BaseView as FABBaseView, expose as FABexpose
 
-
     class RBACMetrics(FABBaseView):
         route_base = "/admin/metrics/"