Skip to content

Commit 8ef5033

Browse files
Lee-Wdor-bernsteineladkal
authored
[v3-1-test] Improve get dag grid structure endpoint speed (#55942) (#56937)
* [v3-1-test] Improve get dag grid structure endpoint speed (#55942) * Improve get dag structure endpoint speed --------- (cherry picked from commit 311277c) Co-authored-by: dor-bernstein <[email protected]> Co-authored-by: Elad Kalif <[email protected]> * fixup! fixup! [v3-1-test] Improve get dag grid structure endpoint speed (#55942) --------- Co-authored-by: dor-bernstein <[email protected]> Co-authored-by: Elad Kalif <[email protected]>
1 parent 5d8860f commit 8ef5033

File tree

1 file changed

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

1 file changed

+3
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,9 @@ def get_dag_structure(
161161

162162
serdags = session.scalars(
163163
select(SerializedDagModel).where(
164+
# Even though dag_id is filtered in base_query,
165+
# adding this line here can improve the performance of this endpoint
166+
SerializedDagModel.dag_id == dag_id,
164167
SerializedDagModel.id != latest_serdag.id,
165168
SerializedDagModel.dag_version_id.in_(
166169
select(TaskInstance.dag_version_id)

0 commit comments

Comments
 (0)