diff --git a/airflow_server/dags/generate_and_send_infographics_images.py b/airflow_server/dags/generate_and_send_infographics_images.py index c6f7f31..62d7221 100644 --- a/airflow_server/dags/generate_and_send_infographics_images.py +++ b/airflow_server/dags/generate_and_send_infographics_images.py @@ -1,7 +1,6 @@ from airflow import DAG import pendulum from anyway_etl_airflow.operators.cli_bash_operator import CliBashOperator -import pendulum dag_kwargs = dict( default_args={ @@ -28,6 +27,7 @@ ) >> \ CliBashOperator( cmd='anyway-etl anyway-kubectl-exec python3 main.py ' - 'telegram send-notification --id {{ dag_run.conf["news_flash_id"] }}', + 'telegram publish-notification --id {{ dag_run.conf["news_flash_id"] }} ' + '--chat {{ dag_run.conf["chat_id"] }}', task_id='send-infographics-to-telegram' - ) + ) \ No newline at end of file