From 68e914ad45b05d12239f55ec5784915b42333117 Mon Sep 17 00:00:00 2001 From: Brent Bovenzi Date: Wed, 8 Jun 2022 10:32:10 -0400 Subject: [PATCH] Check for run_id for grid group summaries --- 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]