Задача запуска воздушного потока, если некоторые из прямых вверх по течению не запущены - PullRequest
0 голосов
/ 26 ноября 2018

У меня есть DAG, у него 5 заданий A, B, C, D, E.и 5 заданий, вызванных вышеперечисленными невыполненными заданиями, по одному для каждого, A_f, B_f, C_f, D_f и E_f (и аналогично пять при успешном выполнении).И наконец, задача X, которая записывает результаты сбоя в базу данных.Скажем, если 2 из первых пяти задач не сработали (A и D), активируются только A_f и D_f.Что я могу сделать, чтобы запустить задачу X?Будет ли работать all_done?даже если некоторые из вышеперечисленных задач никогда не запускались?Я не уверен в этом.

1 Ответ

0 голосов
/ 26 ноября 2018

Да all_done должно работать.Пока ни одна из вышестоящих задач Задачи X не имеет состояния None, которое для любого заданного прогона dag не должно быть возможным, поскольку состояния задач выводятся из состояний предыдущих задач (т. Е. Передается пропущенное состояние или любые дочерние объектыдля невыполненной задачи установлено значение upstream failed), тогда сработает триггер all_done.

...