Как перезапустить невыполненную задачу на Airflow и сохранить запись об ошибке?

Question

Моя группа доступности базы данных выглядит следующим образом:

задача1 >> задача2 >> задача3

и задача2 не выполнена.Я хотел бы перезапустить dagrun с последней точки отказа, которая является task2, и я понимаю, что могу использовать «clear» для этого.

Проблема в том, что при использовании clear попытка выполнения очищается и оглядывается назад.У меня больше нет записей об этой ошибке.

Мне интересно, могу ли я выполнить ее повторно, но сохраню историю ошибок.

Answer 1

Данные об ошибках доступны на вкладке внутри журнала.

Например, если у меня установлено автоматическое повторение попыток на 3, и все 3 не выполнены, в журналах интерфейса пользователя Airflow будет 3 вкладки.

Аналогичным образом, перезапуск невыполненной задачи будет регистрировать новые запуски в новой вкладке.

Он будет находиться под заголовком «Журнал попытками».

Конечно, это также означаетчто вы можете просмотреть их в самих файлах журнала.В файле журнала есть нумерация попыток, указывающая на разницу между попытками.