From 7a0cf9359dee8e5c435668d7547aecde4908dcbc Mon Sep 17 00:00:00 2001 From: Ephraim Anierobi Date: Thu, 30 Oct 2025 08:49:51 +0100 Subject: [PATCH] Eliminate serdag loading added in #56422 It was wrong to load the serdag and not use it. The initial idea was to use the serdag at line 437 but was omitted. Thinking about it now, it will be faster to only load serdag when there's a TI associated with the dag version --- airflow-core/src/airflow/models/serialized_dag.py | 1 - 1 file changed, 1 deletion(-) 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) )