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

astronomer · Jun 8, 2022 · 29e10c5 · 29e10c5
1 parent 01a52cc
commit 29e10c5
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]