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 13326f68a33db..48bd5971461c1 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 @@ -84,14 +84,7 @@ def _get_latest_serdag(dag_id, session): - serdag = session.scalar( - select(SerializedDagModel) - .where( - SerializedDagModel.dag_id == dag_id, - ) - .order_by(SerializedDagModel.id.desc()) - .limit(1) - ) + serdag = session.scalar(SerializedDagModel.latest_item_select_object(dag_id)) if not serdag: raise HTTPException( status.HTTP_404_NOT_FOUND,