Skip to content

Commit 25cb30b

Browse files
committed
DI-1793: Patch prometheus exporter
1 parent 078a151 commit 25cb30b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

airflow_prometheus_exporter/prometheus_exporter.py

+4-4
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,10 @@ def get_dag_duration_info():
9999
),
100100
),
101101
)
102+
.filter(
103+
TaskInstance.start_date.isnot(None),
104+
TaskInstance.end_date.isnot(None),
105+
)
102106
.group_by(
103107
max_execution_dt_query.c.dag_id,
104108
max_execution_dt_query.c.max_execution_dt,
@@ -120,10 +124,6 @@ def get_dag_duration_info():
120124
== dag_start_dt_query.c.execution_date,
121125
),
122126
)
123-
.filter(
124-
TaskInstance.start_date.isnot(None),
125-
TaskInstance.end_date.isnot(None),
126-
)
127127
.all()
128128
)
129129

0 commit comments

Comments
 (0)