Задача DAG Cloud Composer зависит от стороннего сервиса; вам необходимо получать уведомления в случае сбоя задачи. Что вы должны сделать?

Правильный ответ — прикрепить функцию уведомления к параметру onfailurecallback оператора. Этот параметр предназначен для выполнения определенной функции (например, отправки уведомления) в случае сбоя задачи Airflow. Поскольку задача зависит от стороннего сервиса и необходимо получать уведомления при сбое, onfailurecallback является наиболее подходящим механизмом. onretrycallback используется при повторных попытках выполнения задачи, а не при окончательном сбое. slamisscallback срабатывает, когда задача не укладывается в заданное соглашение об уровне обслуживания (SLA), что не обязательно означает сбой. Создание оповещения Cloud Monitoring по метрике slamissed также связано с SLA, а не с непосредственным сбоем задачи, и это менее прямой способ обработки сбоев конкретной задачи Airflow по сравнению с использованием встроенных колбэков оператора.