Рабочий процесс завершен без выполнения всех задач в Airflow

Question

У меня следующий рабочий процесс, за исключением задач ветвления, все остальные задачи реализуются с использованием фиктивных операторов.

Но без выполнения нисходящих задач рабочий процесс переходит в завершенное состояние.

Существуют ли какие-либо конкретные причины для невыполнения (пропуска) нисходящих задач?

Answer 1

Нашли причину и решение в документации по воздушному потоку , используя опцию правил запуска.В соответствии с документацией

В случае этой группы обеспечения доступности баз данных соединение идет после follow_branch_a и branch_false.Задача объединения будет отображаться как пропущенная, потому что ее trigger_rule по умолчанию установлен на all_success, а пропущенные задачи будут каскадно проходить через all_success.

Поэтому я добавил trigger_rule='none_failed' в задачи dss4_dummy, branch3 и end_routine.Что дало мне ожидаемые результаты следующим образом.