We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4dc96c9 commit e26c2fbCopy full SHA for e26c2fb
centralized_metadata/ocrmypdf_processing_dag.py
@@ -15,6 +15,8 @@
15
DEFAULT_PDF_DIRECTORY = str(Path(DEFAULT_SHARE_ROOT) / DEFAULT_RELATIVE_PATH)
16
SHARE_ROOT_VARIABLE = "OCR_PDF_SHARE_ROOT"
17
RELATIVE_PATH_VARIABLE = "OCR_PDF_RELATIVE_PATH"
18
+DEFAULT_SCHEDULE_INTERVAL = "@weekly"
19
+SCHEDULE_INTERVAL_VARIABLE = "OPTIMIZE_PDF_SCHEDULE_INTERVAL"
20
21
DEFAULT_ARGS = {
22
"owner": "airflow",
@@ -126,7 +128,9 @@ def move_processed_pdfs(**context):
126
128
default_args=DEFAULT_ARGS,
127
129
catchup=False,
130
max_active_runs=1,
- schedule_interval=None,
131
+ schedule_interval=Variable.get(
132
+ SCHEDULE_INTERVAL_VARIABLE, default_var=DEFAULT_SCHEDULE_INTERVAL
133
+ ),
134
)
135
136
RUN_OCR = PythonOperator(
0 commit comments