diff --git a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py index de6eac73a9b65..2ad0d54cb8c6a 100644 --- a/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py +++ b/airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py @@ -171,6 +171,7 @@ def get_dag_structure( .where( DagRun.id.in_(run_ids), ) + .distinct() ), ) )