diff --git a/airflow-core/src/airflow/models/serialized_dag.py b/airflow-core/src/airflow/models/serialized_dag.py index c584ab27d92dc..1e75e86aad825 100644 --- a/airflow-core/src/airflow/models/serialized_dag.py +++ b/airflow-core/src/airflow/models/serialized_dag.py @@ -418,7 +418,6 @@ def write_dag( select(DagVersion) .where(DagVersion.dag_id == dag.dag_id) .options(joinedload(DagVersion.task_instances)) - .options(joinedload(DagVersion.serialized_dag)) .order_by(DagVersion.created_at.desc()) .limit(1) )