Update news_flash.py

data-for-change · Mar 25, 2024 · 2221804 · 2221804
1 parent 16d6633
commit 2221804
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/airflow_server/dags/news_flash.py b/airflow_server/dags/news_flash.py
@@ -31,14 +31,21 @@
         task_id='update-news-flash'
     )
 
-with DAG('update-all-news-flash', **dag_kwargs, schedule_interval=None,
+with DAG('update-all-news-flash-location-only', **dag_kwargs, schedule_interval=None,
          description='Update all news flash') as update_all_news_flash_dag:
     CliBashOperator(
         cmd='anyway-etl anyway-kubectl-exec python3 main.py '
         'update-news-flash update --update_cbs_location_only',
         task_id='update-all-news-flash'
     )
 
+with DAG('update-all-news-flash', **dag_kwargs, schedule_interval=None,
+         description='Update all news flash') as update_all_news_flash_dag:
+    CliBashOperator(
+        cmd='anyway-etl anyway-kubectl-exec python3 main.py '
+        'update-news-flash update',
+        task_id='update-all-news-flash'
+    )
 
 with DAG('test-anyway-kubectl-exec', **dag_kwargs, schedule_interval=None) as test_anyway_kubectl_Exec:
     CliBashOperator(