diff --git a/airflow/serialization/serialized_objects.py b/airflow/serialization/serialized_objects.py index d4a4e282ca8631..dc6e4c43b57293 100644 --- a/airflow/serialization/serialized_objects.py +++ b/airflow/serialization/serialized_objects.py @@ -557,7 +557,7 @@ def deserialize_dag(cls, encoded_dag: Dict[str, Any]) -> 'SerializedDAG': k = "task_dict" elif k == "timezone": v = cls._deserialize_timezone(v) - elif k in {"retry_delay", "execution_timeout"}: + elif k in {"dagrun_timeout"}: v = cls._deserialize_timedelta(v) elif k.endswith("_date"): v = cls._deserialize_datetime(v) diff --git a/tests/serialization/test_dag_serialization.py b/tests/serialization/test_dag_serialization.py index cddb6bf9edf256..9dda8785920062 100644 --- a/tests/serialization/test_dag_serialization.py +++ b/tests/serialization/test_dag_serialization.py @@ -301,7 +301,7 @@ def validate_deserialized_dag(self, serialized_dag, dag): "task_ids", "params", "fileloc", "max_active_runs", "concurrency", "is_paused_upon_creation", "doc_md", "safe_dag_id", "is_subdag", "catchup", "description", "start_date", "end_date", "parent_dag", - "template_searchpath", "_access_control" + "template_searchpath", "_access_control", "dagrun_timeout" ] # fields_to_check = dag.get_serialized_fields()