Skip to content

Commit 29e10c5

Browse files
authored
Check for run_id for grid group summaries (apache#24327)
1 parent 01a52cc commit 29e10c5

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

airflow/www/views.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -271,7 +271,9 @@ def task_group_to_grid(task_item_or_group, dag, dag_runs, session):
271271

272272
def get_summary(dag_run, children):
273273
child_instances = [child['instances'] for child in children if 'instances' in child]
274-
child_instances = [item for sublist in child_instances for item in sublist]
274+
child_instances = [
275+
item for sublist in child_instances for item in sublist if item['run_id'] == dag_run.run_id
276+
]
275277

276278
children_start_dates = [item['start_date'] for item in child_instances if item]
277279
children_end_dates = [item['end_date'] for item in child_instances if item]

0 commit comments

Comments
 (0)