Skip to content

Commit 311277c

Browse files
Improve get dag grid structure endpoint speed (apache#55942)
* Improve get dag structure endpoint speed --------- Co-authored-by: Elad Kalif <45845474+eladkal@users.noreply.github.com>
1 parent 3299567 commit 311277c

File tree

1 file changed

+1
-0
lines changed
  • airflow-core/src/airflow/api_fastapi/core_api/routes/ui

1 file changed

+1
-0
lines changed

airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,7 @@ def get_dag_structure(
162162

163163
serdags = session.scalars(
164164
select(SerializedDagModel).where(
165+
SerializedDagModel.dag_id == dag_id,
165166
SerializedDagModel.dag_version_id.in_(
166167
select(TaskInstance.dag_version_id)
167168
.join(TaskInstance.dag_run)

0 commit comments

Comments
 (0)