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

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

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

Чтобы очистить все задачи, нужно: 1

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

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

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