Нет проблем. Это может помочь другим :)
могу настроить Airflow таким образом, чтобы любой сбой в группе обеспечения доступности баз данных (немедленно) приводил к появлению слабого сообщения?
На данный момент я управляю этим путем создания slack_failed_task:
slack_failed_task = SlackAPIPostOperator(
task_id='slack_failed',
channel="#datalabs",
trigger_rule='one_failed',
token="...",
text = ':red_circle: DAG Failed',
icon_url = 'http://airbnb.io/img/projects/airflow3.png',
dag=dag)
И установите эту задачу (one_failed) в восходящем направлении друг от друга в DAG:
slack_failed_task << download_task_a
slack_failed_task << download_task_b
slack_failed_task << process_task_c
slack_failed_task << process_task_d
slack_failed_task << other_task_e
Это работает, но это подвержено ошибкам, так как забыв добавить задачу, пропускает слабые уведомления и кажется большой работой.
Возможно, есть способ расширитьemail_on_failure
недвижимость в DAG?
Бонус ;-) за включение способа передачи имени невыполненной задачи в сообщение.