You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ep...@apache.org on 2022/03/22 19:16:14 UTC
[airflow] 03/31: Fix incorrect data provided to tries & landing times charts (#21928)
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 60b48fa22749dc55d3c22ee64ff454c42cb4dc48
Author: Alexander Millin <a....@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)