Merge pull request #25 from atalyaalon/main

_ fix
data-for-change · Jan 5, 2022 · 7e37f60 · 7e37f60
2 parents 6c33749 + 734713c
commit 7e37f60
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airflow_server/dags/cbs_import_from_s3.py b/airflow_server/dags/cbs_import_from_s3.py
@@ -17,6 +17,6 @@
 with DAG('cbs-import-from-s3', **dag_kwargs) as cbs_import_from_s3:
     CliBashOperator(
         'anyway-etl anyway-kubectl-exec python3 main.py process cbs --source s3'
-        '{% if dag_run.conf.get("load_start_year") %} --load-start-year {{ dag_run.conf["load_start_year"] }}{% endif %}',
+        '{% if dag_run.conf.get("load_start_year") %} --load_start_year {{ dag_run.conf["load_start_year"] }}{% endif %}',
         task_id='cbs-import-from-s3'
     )
diff --git a/airflow_server/dags/import_email_to_s3_and_update_data.py b/airflow_server/dags/import_email_to_s3_and_update_data.py
@@ -20,7 +20,7 @@
         task_id='import-email-to-s3'
     ) >> CliBashOperator(
         'anyway-etl anyway-kubectl-exec python3 main.py process cbs --source s3'
-        '{% if dag_run.conf.get("load_start_year") %} --load-start-year {{ dag_run.conf["load_start_year"] }}{% endif %}',
+        '{% if dag_run.conf.get("load_start_year") %} --load_start_year {{ dag_run.conf["load_start_year"] }}{% endif %}',
         task_id='cbs-import-from-s3'
     ) >> CliBashOperator(
         'anyway-etl anyway-kubectl-exec python3 main.py process infographics-data-cache --update',