Мы недавно приняли Airflow в качестве инструмента для оркестровки. Мы хотим создать DAG контроллера и несколько целевых DAG, чтобы лучше контролировать, какой DAG запускается. Контроллер DAG будет похож на тот, который будет последовательно запускать другие целевые DAG.
Я использовал TriggerDagRunOperator, однако он всегда возвращается успешно, поскольку его задание - только триггер, а не ожидание результата.
Я ожидаю что-то вроде ожидания, пока его состояние не изменится на работоспособное, сбой или т. Д., Затем вызовет dag в нисходящем направлении или прекратит запуск других (в соответствии с результатом первого потока). Есть ли у вас какие-либо предложения?