adding "chat" parameter to generate_and_send_infographics_images

tkalir · Apr 9, 2024 · 45251f5 · 45251f5
1 parent a2d8d84
commit 45251f5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git 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'
-    )
+    )