This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v3-1-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 78ba05687757cf9228129bb6afe0088e8899850a Author: Rahul Vats <[email protected]> AuthorDate: Fri Jan 23 09:54:29 2026 +0530 Fix DAG processor OOM || Avoid loading all TaskInstances when checking DagVersion in write_dag (#60937) Fix DAG processor OOM || Avoid loading all TaskInstances when checking DagVersion in write_dag (#60937) (cherry picked from commit 235595b6c299ccd705ff965704bb20ece9c49fd1) --- airflow-core/src/airflow/models/serialized_dag.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/airflow-core/src/airflow/models/serialized_dag.py b/airflow-core/src/airflow/models/serialized_dag.py index 98d2eefa40e..e714361df9d 100644 --- a/airflow-core/src/airflow/models/serialized_dag.py +++ b/airflow-core/src/airflow/models/serialized_dag.py @@ -28,7 +28,7 @@ from typing import TYPE_CHECKING, Any, Literal import sqlalchemy_jsonfield import uuid6 from sqlalchemy import Column, ForeignKey, LargeBinary, String, exc, exists, select, tuple_, update -from sqlalchemy.orm import backref, foreign, joinedload, relationship +from sqlalchemy.orm import backref, foreign, relationship from sqlalchemy.sql.expression import func, literal from sqlalchemy_utils import UUIDType @@ -417,7 +417,6 @@ class SerializedDagModel(Base): dag_version = session.scalar( select(DagVersion) .where(DagVersion.dag_id == dag.dag_id) - .options(joinedload(DagVersion.task_instances)) .order_by(DagVersion.created_at.desc()) .limit(1) )
