У меня есть Apache Airflow DAG с десятками тысяч задач, и после запуска, скажем, несколько из них не удалось.
Я исправил ошибку, которая приводила к сбою некоторых задач, и я хотел бы повторитьзапускать только неудачные задачи.В этом посте SO предлагается использовать графический интерфейс для «очистки» сбойной задачи:
Как перезапустить сбойную задачу на Airflow
Этот подход работает, если у вас есть несколькоколичество неудачных задач.
Мне интересно, можем ли мы обойти GUI и сделать это проблематично, через командную строку что-то вроде:
airflow_clear_failed_tasks dag_id execution_data