This is an automated email from the ASF dual-hosted git repository.
bbovenzi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 29e10c5f02 Check for run_id for grid group summaries (#24327)
29e10c5f02 is described below
commit 29e10c5f026ad84c1ca4fb00c8f174f6eb3d640f
Author: Brent Bovenzi <[email protected]>
AuthorDate: Wed Jun 8 17:15:54 2022 +0200
Check for run_id for grid group summaries (#24327)
---
airflow/www/views.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/airflow/www/views.py b/airflow/www/views.py
index 25b60cdac9..2c82e33696 100644
--- a/airflow/www/views.py
+++ b/airflow/www/views.py
@@ -271,7 +271,9 @@ def task_group_to_grid(task_item_or_group, dag, dag_runs,
session):
def get_summary(dag_run, children):
child_instances = [child['instances'] for child in children if
'instances' in child]
- child_instances = [item for sublist in child_instances for item in
sublist]
+ child_instances = [
+ item for sublist in child_instances for item in sublist if
item['run_id'] == dag_run.run_id
+ ]
children_start_dates = [item['start_date'] for item in child_instances
if item]
children_end_dates = [item['end_date'] for item in child_instances if
item]
