Airflow 1.9.0 не может поставить задачи в очередь

Question

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

Приложение A: Задача выполнена успешно

Экспонат B: stage_photos не ставится в очередь:

Является ли этоизвестная проблема?У кого-нибудь есть совет?Похоже, это началось с обновления с 1.8 до 1.9, а также только для определенных видов задач (датчики, операторы python, которые возвращают значения).

Answer 1

Я предполагаю, что у вас есть несколько прогонов DAG, которые не удалось, поэтому он не работает с depends_on_past, установленным в True.

Из официальных документов : depends_on_past (логическое значение), которое при значении True препятствует запуску задачи, если предыдущее расписание для задачи не выполнено.

Если, по моим предположениям, предыдущий запуск не был достигнутэто конечное состояние, при котором stage_photos преуспел в предыдущем запуске, это не будет работать в текущем цикле.