Check for run_id for grid group summaries (apache#24327)

(cherry picked from commit 29e10c5)
astronomer · Jun 16, 2022 · 3450105 · 3450105
1 parent 9fab0fc
commit 3450105
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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]