Apache Воздушный поток 1.10.7 Я хотел бы, чтобы пользовательская функция запускалась при отсутствии задачи. Я устанавливаю это свойство во время инициализации dag
def sla_callback_function():
# custom logic
dag=DAG('sla_test', default_args=default_args, schedule_interval='00 10 * * *', sla_miss_callback=sla_callback_function)
Время SLA установлено на уровне задачи (только 1 задача). Я получил электронные письма об отсутствии SLA и вижу пропуски SLA в пользовательском интерфейсе, но не вижу срабатывания пользовательской функции.