Skip to content

Commit

Permalink
Feature 2321 creating telegram push notifications fix cli command in …
Browse files Browse the repository at this point in the history
…dag (#53)

* fix "upload generated_infographics" -> "upload generated-infographics"

* adding "chat" parameter to generate_and_send_infographics_images
  • Loading branch information
tkalir authored Apr 9, 2024
1 parent 8cef52b commit 3000162
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions airflow_server/dags/generate_and_send_infographics_images.py
Original file line number Diff line number Diff line change
@@ -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={
Expand All @@ -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'
)
)

0 comments on commit 3000162

Please sign in to comment.