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 c35d621a7ddfd..0c475c985dda5 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 @@ -161,6 +161,9 @@ def get_dag_structure( serdags = session.scalars( select(SerializedDagModel).where( + # Even though dag_id is filtered in base_query, + # adding this line here can improve the performance of this endpoint + SerializedDagModel.dag_id == dag_id, SerializedDagModel.id != latest_serdag.id, SerializedDagModel.dag_version_id.in_( select(TaskInstance.dag_version_id)