From 2c57ad4ff9ddde8102c62f2e25c2a2e82cceb3e7 Mon Sep 17 00:00:00 2001 From: Alexander Millin Date: Wed, 2 Mar 2022 13:29:07 +0300 Subject: [PATCH] Fix incorrect data provided to tries & landing times charts (#21928) --- airflow/www/views.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/airflow/www/views.py b/airflow/www/views.py index 19d8181a47883..f9138382f1505 100644 --- a/airflow/www/views.py +++ b/airflow/www/views.py @@ -2907,6 +2907,8 @@ def tries(self, dag_id, session=None): y_points = [] x_points = [] for ti in tis: + if ti.task_id != task.task_id: + continue dttm = wwwutils.epoch(ti.execution_date) x_points.append(dttm) # y value should reflect completed tries to have a 0 baseline. @@ -2998,6 +3000,8 @@ def landing_times(self, dag_id, session=None): y_points[task_id] = [] x_points[task_id] = [] for ti in tis: + if ti.task_id != task.task_id: + continue ts = dag.get_run_data_interval(ti.dag_run).end if ti.end_date: dttm = wwwutils.epoch(ti.execution_date)