25
25
import sys
26
26
import textwrap
27
27
import traceback
28
- import warnings
29
28
import zipfile
30
29
from datetime import datetime , timedelta
31
30
from pathlib import Path
47
46
AirflowDagCycleException ,
48
47
AirflowDagDuplicatedIdException ,
49
48
AirflowException ,
50
- RemovedInAirflow3Warning ,
51
49
)
52
50
from airflow .listeners .listener import get_listener_manager
53
51
from airflow .models .base import Base
@@ -113,7 +111,6 @@ class DagBag(LoggingMixin):
113
111
to filter python modules to scan for dags.
114
112
:param read_dags_from_db: Read DAGs from DB if ``True`` is passed.
115
113
If ``False`` DAGs are read from python files.
116
- :param store_serialized_dags: deprecated parameter, same effect as `read_dags_from_db`
117
114
:param load_op_links: Should the extra operator link be loaded via plugins when
118
115
de-serializing the DAG? This flag is set to False in Scheduler so that Extra Operator links
119
116
are not loaded to not run User code in Scheduler.
@@ -126,7 +123,6 @@ def __init__(
126
123
include_examples : bool | ArgNotSet = NOTSET ,
127
124
safe_mode : bool | ArgNotSet = NOTSET ,
128
125
read_dags_from_db : bool = False ,
129
- store_serialized_dags : bool | None = None ,
130
126
load_op_links : bool = True ,
131
127
collect_dags : bool = True ,
132
128
):
@@ -143,15 +139,6 @@ def __init__(
143
139
safe_mode if isinstance (safe_mode , bool ) else conf .getboolean ("core" , "DAG_DISCOVERY_SAFE_MODE" )
144
140
)
145
141
146
- if store_serialized_dags :
147
- warnings .warn (
148
- "The store_serialized_dags parameter has been deprecated. "
149
- "You should pass the read_dags_from_db parameter." ,
150
- RemovedInAirflow3Warning ,
151
- stacklevel = 2 ,
152
- )
153
- read_dags_from_db = store_serialized_dags
154
-
155
142
dag_folder = dag_folder or settings .DAGS_FOLDER
156
143
self .dag_folder = dag_folder
157
144
self .dags : dict [str , DAG ] = {}
@@ -182,16 +169,6 @@ def size(self) -> int:
182
169
""":return: the amount of dags contained in this dagbag"""
183
170
return len (self .dags )
184
171
185
- @property
186
- def store_serialized_dags (self ) -> bool :
187
- """Whether to read dags from DB."""
188
- warnings .warn (
189
- "The store_serialized_dags property has been deprecated. Use read_dags_from_db instead." ,
190
- RemovedInAirflow3Warning ,
191
- stacklevel = 2 ,
192
- )
193
- return self .read_dags_from_db
194
-
195
172
@property
196
173
def dag_ids (self ) -> list [str ]:
197
174
"""
0 commit comments