Skip to content

Commit 26f95ae

Browse files
authored
DEVO-571 Fix schedule_interval deprecation warning (#979)
1 parent a366813 commit 26f95ae

11 files changed

+11
-11
lines changed

cob_datapipeline/alma_electronic_notes_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@
4747
default_args=DEFAULT_ARGS,
4848
catchup=False,
4949
max_active_runs=1,
50-
schedule_interval="@weekly"
50+
schedule="@weekly"
5151
)
5252

5353
"""

cob_datapipeline/boundwith_move_alma_sftp_to_s3_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
default_args=DEFAULT_ARGS,
3333
catchup=False,
3434
max_active_runs=1,
35-
schedule_interval=None
35+
schedule=None
3636
)
3737

3838
def calculate_list_of_files_to_move(**context):

cob_datapipeline/catalog_full_reindex_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@
6969
catchup=False,
7070
default_args=DEFAULT_ARGS,
7171
max_active_runs=1,
72-
schedule_interval=None
72+
schedule=None
7373
)
7474

7575
"""

cob_datapipeline/catalog_move_alma_sftp_to_s3_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@
3232
default_args=DEFAULT_ARGS,
3333
catchup=False,
3434
max_active_runs=1,
35-
schedule_interval=None
35+
schedule=None
3636
)
3737

3838
def calculate_list_of_files_to_move(**context):

cob_datapipeline/catalog_preproduction_oai_harvest_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@
8181
catchup=False,
8282
default_args=DEFAULT_ARGS,
8383
max_active_runs=1,
84-
schedule_interval=timedelta(hours=int(CATALOG_OAI_PUBLISH_INTERVAL))
84+
schedule=timedelta(hours=int(CATALOG_OAI_PUBLISH_INTERVAL))
8585
)
8686

8787
"""

cob_datapipeline/catalog_production_oai_harvest_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@
8181
catchup=False,
8282
default_args=DEFAULT_ARGS,
8383
max_active_runs=1,
84-
schedule_interval=timedelta(hours=int(CATALOG_OAI_PUBLISH_INTERVAL))
84+
schedule=timedelta(hours=int(CATALOG_OAI_PUBLISH_INTERVAL))
8585
)
8686

8787
"""

cob_datapipeline/dspace_harvest_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@
5252
default_args=DEFAULT_ARGS,
5353
catchup=False,
5454
max_active_runs=1,
55-
schedule_interval=None
55+
schedule=None
5656
)
5757

5858
"""

cob_datapipeline/prod_az_reindex_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@
5454
default_args=DEFAULT_ARGS,
5555
catchup=False,
5656
max_active_runs=1,
57-
schedule_interval=SCHEDULE_INTERVAL
57+
schedule=SCHEDULE_INTERVAL
5858
)
5959

6060
"""

cob_datapipeline/prod_web_content_reindex_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@
5252
default_args=DEFAULT_ARGS,
5353
catchup=False,
5454
max_active_runs=1,
55-
schedule_interval=SCHEDULE_INTERVAL
55+
schedule=SCHEDULE_INTERVAL
5656
)
5757

5858
"""

cob_datapipeline/qa_az_reindex_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@
5454
default_args=DEFAULT_ARGS,
5555
catchup=False,
5656
max_active_runs=1,
57-
schedule_interval=SCHEDULE_INTERVAL
57+
schedule=SCHEDULE_INTERVAL
5858
)
5959

6060
"""

cob_datapipeline/qa_web_content_reindex_dag.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@
5757
default_args=DEFAULT_ARGS,
5858
catchup=False,
5959
max_active_runs=1,
60-
schedule_interval=SCHEDULE_INTERVAL
60+
schedule=SCHEDULE_INTERVAL
6161
)
6262

6363
"""

0 commit comments

Comments
 (0)