Почему trigger_dag не запускается из-за неудачной задачи после перезапуска в потоке воздуха?

Question

Почему команда trigger_dag в cli не запускается из сбойной задачи после перезапуска?

Я использую Triggerdanrunoperator для внешнего запуска DAG. При перезапуске dagrun должен запускаться с того места, где произошел сбой.

Есть ли способы достичь? Пожалуйста, помогите.

Answer 1

Используйте команду очистки воздушного потока.

Вы можете указать --only_failed или --task_regex с флагами --downstream.

Доко здесь: https://airflow.apache.org/cli.html#clear