неуспешная задача, основанная на Debian_on_past в операторах воздушного потока

Question

Допустим, у меня есть даг, в котором одна задача зависит от 4 задач. Все 4 задачи должны запускаться только в том случае, если та же задача предыдущего запуска dag была успешной. Таким образом, все задачи имеют значение depends_on_past как True. Однако последняя задача дага - это задача очистки, которая всегда должна запускаться. Таким образом, в случае сбоя задачи предыдущего дня задача текущего дня не запускается, поэтому последняя задача также не запускается. Как можно решить эту проблему?

Answer 1

Всегда устанавливайте trigger_rule=TriggerRule.ALL_DONE в ваших задачах очистки (те задачи, которые должны выполняться всегда, независимо от статуса восходящих задач)

И хотя вы, кажется, уже поняли это, также может иметь смысл установить depends_on_past=False в ваших задачах очистки