diff --git a/airflow/models/dagbag.py b/airflow/models/dagbag.py index 3fa3af180c92d..561564a5e9323 100644 --- a/airflow/models/dagbag.py +++ b/airflow/models/dagbag.py @@ -25,7 +25,6 @@ import sys import textwrap import traceback -import warnings import zipfile from datetime import datetime, timedelta from pathlib import Path @@ -47,7 +46,6 @@ AirflowDagCycleException, AirflowDagDuplicatedIdException, AirflowException, - RemovedInAirflow3Warning, ) from airflow.listeners.listener import get_listener_manager from airflow.models.base import Base @@ -113,7 +111,6 @@ class DagBag(LoggingMixin): to filter python modules to scan for dags. :param read_dags_from_db: Read DAGs from DB if ``True`` is passed. If ``False`` DAGs are read from python files. - :param store_serialized_dags: deprecated parameter, same effect as `read_dags_from_db` :param load_op_links: Should the extra operator link be loaded via plugins when de-serializing the DAG? This flag is set to False in Scheduler so that Extra Operator links are not loaded to not run User code in Scheduler. @@ -126,7 +123,6 @@ def __init__( include_examples: bool | ArgNotSet = NOTSET, safe_mode: bool | ArgNotSet = NOTSET, read_dags_from_db: bool = False, - store_serialized_dags: bool | None = None, load_op_links: bool = True, collect_dags: bool = True, ): @@ -143,15 +139,6 @@ def __init__( safe_mode if isinstance(safe_mode, bool) else conf.getboolean("core", "DAG_DISCOVERY_SAFE_MODE") ) - if store_serialized_dags: - warnings.warn( - "The store_serialized_dags parameter has been deprecated. " - "You should pass the read_dags_from_db parameter.", - RemovedInAirflow3Warning, - stacklevel=2, - ) - read_dags_from_db = store_serialized_dags - dag_folder = dag_folder or settings.DAGS_FOLDER self.dag_folder = dag_folder self.dags: dict[str, DAG] = {} @@ -182,16 +169,6 @@ def size(self) -> int: """:return: the amount of dags contained in this dagbag""" return len(self.dags) - @property - def store_serialized_dags(self) -> bool: - """Whether to read dags from DB.""" - warnings.warn( - "The store_serialized_dags property has been deprecated. Use read_dags_from_db instead.", - RemovedInAirflow3Warning, - stacklevel=2, - ) - return self.read_dags_from_db - @property def dag_ids(self) -> list[str]: """ diff --git a/newsfragments/40931.significant.rst b/newsfragments/40931.significant.rst new file mode 100644 index 0000000000000..b5d47f0c36b8a --- /dev/null +++ b/newsfragments/40931.significant.rst @@ -0,0 +1 @@ +Removed dagbag deprecated ``store_serialized_dags`` parameter. Please use ``read_dags_from_db`` parameter.