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 38acbfe6bb32509856a65baf8f14a19024c20d0e
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)
