запускать только последующие задачи, а не текущую задачу - поток воздуха

Question

У меня есть Airflow DAG, которая как одна upstream задача и около 40 downstream задач из этой upstream (например, от 1 до 40 сопоставлений). upstream завершился успешно, и по какой-то причине мне пришлось остановить задания downstream. Теперь я хочу выполнить их все. Есть ли способ сделать это, просто выполнив одну команду (вместо очистки каждого отдельного нисходящего потока)? Неважно, из веб-интерфейса или из терминала.

Answer 1

Если вы хотите повторно выполнить все последующие задачи одновременно, щелкните 1 восходящую задачу в пользовательском интерфейсе DAG и откройте ее пользовательский интерфейс. Нажмите «Downstream», «Clear» и подтвердите, что вы хотите очистить все выбранные задачи. Как только это будет выполнено, пометьте 1 восходящую задачу как успешную. После этого все последующие задачи забудут свое предыдущее состояние и выполнятся повторно.