Как повторить попытку Airflow DAG?

Question

Я знаю, что можно повторить отдельные задачи, но можно ли повторить попытку завершить DAG?

Я создаю задачи динамически, поэтому мне нужно повторить не конкретную задачу, а полную DAG. Если это не поддерживается Airflow, возможно, есть какое-то решение.

Answer 1

Зайдите в Airflow UI, нажмите на первое (ые) задание (я) вашей группы доступности базы данных, справа от кнопки «Очистить» выберите «Вниз по течению» и «Рекурсивно» и после этого нажмите «Очистить». Это помечает группу обеспечения доступности баз данных как «еще не выполнено» и запускает ее повторно, если расписание группы доступности базы данных это разрешает

Answer 2

Если у вас есть доступ к пользовательскому интерфейсу Airflow, перейдите к представлению «График».

В представлении «График» отдельные задачи помечаются как блоки, а прогон DAG в целом обозначается кружками. Нажмите на кружок, а затем вариант clear. Это перезапустит весь прогон.

В качестве альтернативы вы можете перейти к представлению в виде дерева и clear к первой задаче в группе обеспечения доступности баз данных.