This is an automated email from the ASF dual-hosted git repository.
husseinawala 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 ab0295fe041 [WEBSERVER] SerializedDagModel query bug fix impacting
Grid view performance (#56257) (#56938)
ab0295fe041 is described below
commit ab0295fe041c99d60f60d2ccdd4a79f54fb50c6c
Author: Wei Lee <[email protected]>
AuthorDate: Tue Oct 21 20:39:23 2025 +0800
[WEBSERVER] SerializedDagModel query bug fix impacting Grid view
performance (#56257) (#56938)
(cherry picked from commit 130f4ae19998aceca014e35a5ec324ccc4685e01)
Co-authored-by: Hussein Awala <[email protected]>
---
airflow-core/src/airflow/api_fastapi/core_api/routes/ui/grid.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 6099fb55948..c35d621a7dd 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,14 +161,14 @@ def get_dag_structure(
serdags = session.scalars(
select(SerializedDagModel).where(
+ SerializedDagModel.id != latest_serdag.id,
SerializedDagModel.dag_version_id.in_(
select(TaskInstance.dag_version_id)
.join(TaskInstance.dag_run)
.where(
DagRun.id.in_(run_ids),
- SerializedDagModel.id != latest_serdag.id,
)
- )
+ ),
)
)
merged_nodes: list[dict[str, Any]] = []
