This is an automated email from the ASF dual-hosted git repository.
kaxilnaik pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-1-test by this push:
new 8ef503336f9 [v3-1-test] Improve get dag grid structure endpoint speed
(#55942) (#56937)
8ef503336f9 is described below
commit 8ef503336f9d778bb2b75ed5fcf0c1259c83079e
Author: Wei Lee <[email protected]>
AuthorDate: Tue Oct 21 23:17:19 2025 +0800
[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]>
---
airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py | 3 +++
1 file changed, 3 insertions(+)
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 c35d621a7dd..0c475c985dd 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)
