From c1a6db1d71570cfabc93de8fc6f4fbcad2495485 Mon Sep 17 00:00:00 2001 From: Atalya Alon <20992625+atalyaalon@users.noreply.github.com> Date: Wed, 14 Feb 2024 23:16:32 +0200 Subject: [PATCH] Update news_flash.py --- airflow_server/dags/news_flash.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/airflow_server/dags/news_flash.py b/airflow_server/dags/news_flash.py index 8409cce..24e92e7 100644 --- a/airflow_server/dags/news_flash.py +++ b/airflow_server/dags/news_flash.py @@ -31,6 +31,14 @@ task_id='update-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 --update_cbs_location_only', + task_id='update-all-news-flash' + ) + with DAG('test-anyway-kubectl-exec', **dag_kwargs, schedule_interval=None) as test_anyway_kubectl_Exec: CliBashOperator(