This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-2-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 94905e5f818b7859fe0694ebded2e8c813a9261d Author: Alexander Millin <a.mil...@city-mobil.ru> AuthorDate: Wed Mar 2 13:29:07 2022 +0300 Fix incorrect data provided to tries & landing times charts (#21928) (cherry picked from commit 2c57ad4ff9ddde8102c62f2e25c2a2e82cceb3e7) --- airflow/www/views.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/airflow/www/views.py b/airflow/www/views.py index 9ebe899..9fc61b5 100644 --- a/airflow/www/views.py +++ b/airflow/www/views.py @@ -2727,6 +2727,8 @@ class Airflow(AirflowBaseView): 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. @@ -2802,6 +2804,8 @@ class Airflow(AirflowBaseView): 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)