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

Очистка невыполненных задач в Airflow происходит с помощью команды backfill. www.upsolver.com bigdataschool.ru Она позволяет запустить задачу или подраздел DAG для указанного диапазона дат. bigdataschool.ru

Некоторые возможности команды backfill:

• Опция resetdagrun. bigdataschool.ru AirFlow спрашивает у пользователя, нужно ли очистить все предыдущие экземпляры dagrun и taskinstances в указанном диапазоне дат. bigdataschool.ru
• Опция rerunfailedtasks. bigdataschool.ru Backfill автоматически повторно запускает предыдущие неудачно выполненные экземпляры задачи в заданном диапазоне дат. bigdataschool.ru

Чтобы очистить все задачи, нужно: www.astronomer.io

1. В интерфейсе Airflow перейти в раздел «Просмотр» > «Экземпляры задач». www.astronomer.io
2. Выбрать задачи для перезапуска. www.astronomer.io
3. В списке «Действия» выбрать «Очистить». www.astronomer.io

Для перезапуска нескольких DAG нужно нажать «Просмотр» > «Запуски DAG», выбрать нужные DAG и в списке «Действия» выбрать «Очистить состояние». www.astronomer.io

Важно: не следует очищать или менять статус задач напрямую в метасторе Airflow, это может привести к неожиданному поведению. www.astronomer.io