Как очистить состояние запуска dag с помощью CLI в airflow / composer?

Question

Я думал, что смогу использовать команду:

g beta composer environments run <env> --location=us-central1 clear -- <dag_id> -s 2018-05-13 -e 2018-05-14

Очистка состояния dag выполняется на 2018-05-13.По какой-то причине это не работает.Что происходит, что CLI зависает на сообщении, подобном:

kubeconfig entry generated for <kube node name>.

Каково ожидаемое поведение команды выше?Я ожидал бы, что он очистит пробежку за интервал, но, возможно, я делаю что-то не так.

Answer 1

Запуск clear в Cloud Composer требует добавления параметра -c в команду следующим образом:

g beta composer environments run <env> --location=us-central1 clear -- <dag_id> -c -s 2018-05-13 -e 2018-05-14

Answer 2

Поведение команды, которую вы написали, такое же, как и при запуске airflow clear в локальной установке.Может быть, команда просто работает медленно?Можете ли вы наблюдать какие-либо изменения в экземплярах задач, отображаемых в веб-интерфейсе Airflow?