diff --git a/airflow_server/dags/news_flash.py b/airflow_server/dags/news_flash.py index 24e92e7..0e3c7f3 100644 --- a/airflow_server/dags/news_flash.py +++ b/airflow_server/dags/news_flash.py @@ -31,7 +31,7 @@ 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 ' @@ -39,6 +39,13 @@ 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(