@@ -12,16 +12,14 @@ AIR301 [*] `schedule_interval` is removed in Airflow 3.0
121223 | DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
1313 |
1414help : Use ` schedule` instead
15-
16- ℹ Safe fix
17- 18 18 |
18- 19 19 | DAG (dag_id = " class_schedule" , schedule = " @hourly" )
19- 20 20 |
20- 21 | - DAG (dag_id = " class_schedule_interval" , schedule_interval = " @hourly" )
21- 21 | + DAG (dag_id = " class_schedule_interval" , schedule = " @hourly" )
22- 22 22 |
23- 23 23 | DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
24- 24 24 |
15+ 18 |
16+ 19 | DAG (dag_id = " class_schedule" , schedule = " @hourly" )
17+ 20 |
18+ - DAG (dag_id = " class_schedule_interval" , schedule_interval = " @hourly" )
19+ 21 + DAG (dag_id = " class_schedule_interval" , schedule = " @hourly" )
20+ 22 |
21+ 23 | DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
22+ 24 |
2523
2624AIR301 [* ] ` timetable` is removed in Airflow 3.0
2725 -- > AIR301_args .py :23 :31
@@ -32,16 +30,14 @@ AIR301 [*] `timetable` is removed in Airflow 3.0
3230 | ^^^^^^^^^
3331 |
3432help : Use ` schedule` instead
35-
36- ℹ Safe fix
37- 20 20 |
38- 21 21 | DAG (dag_id = " class_schedule_interval" , schedule_interval = " @hourly" )
39- 22 22 |
40- 23 | - DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
41- 23 | + DAG (dag_id = " class_timetable" , schedule = NullTimetable ())
42- 24 24 |
43- 25 25 |
44- 26 26 | DAG (dag_id = " class_fail_stop" , fail_stop = True )
33+ 20 |
34+ 21 | DAG (dag_id = " class_schedule_interval" , schedule_interval = " @hourly" )
35+ 22 |
36+ - DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
37+ 23 + DAG (dag_id = " class_timetable" , schedule = NullTimetable ())
38+ 24 |
39+ 25 |
40+ 26 | DAG (dag_id = " class_fail_stop" , fail_stop = True )
4541
4642AIR301 [* ] ` fail_stop` is removed in Airflow 3.0
4743 -- > AIR301_args .py :26 :31
@@ -52,16 +48,14 @@ AIR301 [*] `fail_stop` is removed in Airflow 3.0
524828 | DAG (dag_id = " class_default_view" , default_view = " dag_default_view" )
5349 |
5450help : Use ` fail_fast` instead
55-
56- ℹ Safe fix
57- 23 23 | DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
58- 24 24 |
59- 25 25 |
60- 26 | - DAG (dag_id = " class_fail_stop" , fail_stop = True )
61- 26 | + DAG (dag_id = " class_fail_stop" , fail_fast = True )
62- 27 27 |
63- 28 28 | DAG (dag_id = " class_default_view" , default_view = " dag_default_view" )
64- 29 29 |
51+ 23 | DAG (dag_id = " class_timetable" , timetable = NullTimetable ())
52+ 24 |
53+ 25 |
54+ - DAG (dag_id = " class_fail_stop" , fail_stop = True )
55+ 26 + DAG (dag_id = " class_fail_stop" , fail_fast = True )
56+ 27 |
57+ 28 | DAG (dag_id = " class_default_view" , default_view = " dag_default_view" )
58+ 29 |
6559
6660AIR301 ` default_view` is removed in Airflow 3.0
6761 -- > AIR301_args .py :28 :34
@@ -94,16 +88,14 @@ AIR301 [*] `schedule_interval` is removed in Airflow 3.0
948843 | pass
9589 |
9690help : Use ` schedule` instead
97-
98- ℹ Safe fix
99- 38 38 | pass
100- 39 39 |
101- 40 40 |
102- 41 | - @dag (schedule_interval = " 0 * * * *" )
103- 41 | + @dag (schedule = " 0 * * * *" )
104- 42 42 | def decorator_schedule_interval ():
105- 43 43 | pass
106- 44 44 |
91+ 38 | pass
92+ 39 |
93+ 40 |
94+ - @dag (schedule_interval = " 0 * * * *" )
95+ 41 + @dag (schedule = " 0 * * * *" )
96+ 42 | def decorator_schedule_interval ():
97+ 43 | pass
98+ 44 |
10799
108100AIR301 [* ] ` timetable` is removed in Airflow 3.0
109101 -- > AIR301_args .py :46 :6
@@ -114,16 +106,14 @@ AIR301 [*] `timetable` is removed in Airflow 3.0
11410648 | pass
115107 |
116108help : Use ` schedule` instead
117-
118- ℹ Safe fix
119- 43 43 | pass
120- 44 44 |
121- 45 45 |
122- 46 | - @dag (timetable = NullTimetable ())
123- 46 | + @dag (schedule = NullTimetable ())
124- 47 47 | def decorator_timetable ():
125- 48 48 | pass
126- 49 49 |
109+ 43 | pass
110+ 44 |
111+ 45 |
112+ - @dag (timetable = NullTimetable ())
113+ 46 + @dag (schedule = NullTimetable ())
114+ 47 | def decorator_timetable ():
115+ 48 | pass
116+ 49 |
127117
128118AIR301 [* ] ` execution_date` is removed in Airflow 3.0
129119 -- > AIR301_args .py :54 :62
@@ -136,16 +126,14 @@ AIR301 [*] `execution_date` is removed in Airflow 3.0
13612656 | trigger_dagrun_op2 = TriggerDagRunOperator (
137127 |
138128help : Use ` logical_date` instead
139-
140- ℹ Safe fix
141- 51 51 | @dag ()
142- 52 52 | def decorator_deprecated_operator_args ():
143- 53 53 | trigger_dagrun_op = trigger_dagrun .TriggerDagRunOperator (
144- 54 | - task_id = " trigger_dagrun_op1" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
145- 54 | + task_id = " trigger_dagrun_op1" , trigger_dag_id = " test" , logical_date = " 2024-12-04"
146- 55 55 | )
147- 56 56 | trigger_dagrun_op2 = TriggerDagRunOperator (
148- 57 57 | task_id = " trigger_dagrun_op2" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
129+ 51 | @dag ()
130+ 52 | def decorator_deprecated_operator_args ():
131+ 53 | trigger_dagrun_op = trigger_dagrun .TriggerDagRunOperator (
132+ - task_id = " trigger_dagrun_op1" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
133+ 54 + task_id = " trigger_dagrun_op1" , trigger_dag_id = " test" , logical_date = " 2024-12-04"
134+ 55 | )
135+ 56 | trigger_dagrun_op2 = TriggerDagRunOperator (
136+ 57 | task_id = " trigger_dagrun_op2" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
149137
150138AIR301 [* ] ` execution_date` is removed in Airflow 3.0
151139 -- > AIR301_args .py :57 :62
@@ -157,16 +145,14 @@ AIR301 [*] `execution_date` is removed in Airflow 3.0
15714558 | )
158146 |
159147help : Use ` logical_date` instead
160-
161- ℹ Safe fix
162- 54 54 | task_id = " trigger_dagrun_op1" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
163- 55 55 | )
164- 56 56 | trigger_dagrun_op2 = TriggerDagRunOperator (
165- 57 | - task_id = " trigger_dagrun_op2" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
166- 57 | + task_id = " trigger_dagrun_op2" , trigger_dag_id = " test" , logical_date = " 2024-12-04"
167- 58 58 | )
168- 59 59 |
169- 60 60 | branch_dt_op = datetime .BranchDateTimeOperator (
148+ 54 | task_id = " trigger_dagrun_op1" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
149+ 55 | )
150+ 56 | trigger_dagrun_op2 = TriggerDagRunOperator (
151+ - task_id = " trigger_dagrun_op2" , trigger_dag_id = " test" , execution_date = " 2024-12-04"
152+ 57 + task_id = " trigger_dagrun_op2" , trigger_dag_id = " test" , logical_date = " 2024-12-04"
153+ 58 | )
154+ 59 |
155+ 60 | branch_dt_op = datetime .BranchDateTimeOperator (
170156
171157AIR301 [* ] ` use_task_execution_day` is removed in Airflow 3.0
172158 -- > AIR301_args .py :61 :33
@@ -178,16 +164,14 @@ AIR301 [*] `use_task_execution_day` is removed in Airflow 3.0
17816463 | branch_dt_op2 = BranchDateTimeOperator (
179165 |
180166help : Use ` use_task_logical_date` instead
181-
182- ℹ Safe fix
183- 58 58 | )
184- 59 59 |
185- 60 60 | branch_dt_op = datetime .BranchDateTimeOperator (
186- 61 | - task_id = " branch_dt_op" , use_task_execution_day = True , task_concurrency = 5
187- 61 | + task_id = " branch_dt_op" , use_task_logical_date = True , task_concurrency = 5
188- 62 62 | )
189- 63 63 | branch_dt_op2 = BranchDateTimeOperator (
190- 64 64 | task_id = " branch_dt_op2" ,
167+ 58 | )
168+ 59 |
169+ 60 | branch_dt_op = datetime .BranchDateTimeOperator (
170+ - task_id = " branch_dt_op" , use_task_execution_day = True , task_concurrency = 5
171+ 61 + task_id = " branch_dt_op" , use_task_logical_date = True , task_concurrency = 5
172+ 62 | )
173+ 63 | branch_dt_op2 = BranchDateTimeOperator (
174+ 64 | task_id = " branch_dt_op2" ,
191175
192176AIR301 [* ] ` task_concurrency` is removed in Airflow 3.0
193177 -- > AIR301_args .py :61 :62
@@ -199,16 +183,14 @@ AIR301 [*] `task_concurrency` is removed in Airflow 3.0
19918363 | branch_dt_op2 = BranchDateTimeOperator (
200184 |
201185help : Use ` max_active_tis_per_dag` instead
202-
203- ℹ Safe fix
204- 58 58 | )
205- 59 59 |
206- 60 60 | branch_dt_op = datetime .BranchDateTimeOperator (
207- 61 | - task_id = " branch_dt_op" , use_task_execution_day = True , task_concurrency = 5
208- 61 | + task_id = " branch_dt_op" , use_task_execution_day = True , max_active_tis_per_dag = 5
209- 62 62 | )
210- 63 63 | branch_dt_op2 = BranchDateTimeOperator (
211- 64 64 | task_id = " branch_dt_op2" ,
186+ 58 | )
187+ 59 |
188+ 60 | branch_dt_op = datetime .BranchDateTimeOperator (
189+ - task_id = " branch_dt_op" , use_task_execution_day = True , task_concurrency = 5
190+ 61 + task_id = " branch_dt_op" , use_task_execution_day = True , max_active_tis_per_dag = 5
191+ 62 | )
192+ 63 | branch_dt_op2 = BranchDateTimeOperator (
193+ 64 | task_id = " branch_dt_op2" ,
212194
213195AIR301 [* ] ` use_task_execution_day` is removed in Airflow 3.0
214196 -- > AIR301_args .py :65 :9
@@ -221,16 +203,14 @@ AIR301 [*] `use_task_execution_day` is removed in Airflow 3.0
22120367 | )
222204 |
223205help : Use ` use_task_logical_date` instead
224-
225- ℹ Safe fix
226- 62 62 | )
227- 63 63 | branch_dt_op2 = BranchDateTimeOperator (
228- 64 64 | task_id = " branch_dt_op2" ,
229- 65 | - use_task_execution_day = True ,
230- 65 | + use_task_logical_date = True ,
231- 66 66 | sla = timedelta (seconds = 10 ),
232- 67 67 | )
233- 68 68 |
206+ 62 | )
207+ 63 | branch_dt_op2 = BranchDateTimeOperator (
208+ 64 | task_id = " branch_dt_op2" ,
209+ - use_task_execution_day = True ,
210+ 65 + use_task_logical_date = True ,
211+ 66 | sla = timedelta (seconds = 10 ),
212+ 67 | )
213+ 68 |
234214
235215AIR301 [* ] ` use_task_execution_day` is removed in Airflow 3.0
236216 -- > AIR301_args .py :92 :9
@@ -242,16 +222,14 @@ AIR301 [*] `use_task_execution_day` is removed in Airflow 3.0
24222293 | )
243223 |
244224help : Use ` use_task_logical_date` instead
245-
246- ℹ Safe fix
247- 89 89 | follow_task_ids_if_false = None ,
248- 90 90 | follow_task_ids_if_true = None ,
249- 91 91 | week_day = 1 ,
250- 92 | - use_task_execution_day = True ,
251- 92 | + use_task_logical_date = True ,
252- 93 93 | )
253- 94 94 |
254- 95 95 | trigger_dagrun_op >> trigger_dagrun_op2
225+ 89 | follow_task_ids_if_false = None ,
226+ 90 | follow_task_ids_if_true = None ,
227+ 91 | week_day = 1 ,
228+ - use_task_execution_day = True ,
229+ 92 + use_task_logical_date = True ,
230+ 93 | )
231+ 94 |
232+ 95 | trigger_dagrun_op >> trigger_dagrun_op2
255233
256234AIR301 ` filename_template` is removed in Airflow 3.0
257235 -- > AIR301_args .py :102 :15
0 commit comments