Нет проблем. Это может помочь другим :)

могу настроить 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?

Бонус ;-) за включение способа передачи имени невыполненной задачи в сообщение.

Ответы на вопрос(3)

Ваш ответ на вопрос