From 29e10c5f026ad84c1ca4fb00c8f174f6eb3d640f Mon Sep 17 00:00:00 2001 From: Brent Bovenzi Date: Wed, 8 Jun 2022 17:15:54 +0200 Subject: [PATCH] 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 25b60cdac9cf7..2c82e336967f5 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]