Как остановить запуск задач Airflow от «выключенных» ярлыков

Question

Я создал несколько групп DAG, запустил их и остановил в середине их выполнения (с помощью кнопки OFF).

Тем не менее пользовательский интерфейс по-прежнему отображает «Выполнение задач» для этих остановленных групп DAG.Я попытался установить «очистить» для этих задач, а они не отображаются синим цветом в состоянии «выключения».

Мне интересно, учитываются ли эти задачи в общем количестве запущенных задач и блокирует запуск других задач(в моей текущей конфигурации только 32 задачи могут выполняться параллельно).Есть ли способ полностью очистить группы DAG, которые мне больше не нужны, и убедиться, что задачи ничего не блокируют и не замедляют воздушный поток?

Спасибо!

Answer 1

Вы можете удалить все данные dag из таблиц dag_run и task_instances в базе метаданных.

Это также можно сделать с помощью пользовательского интерфейса веб-сервера Airflow, перейдя к

Обзор -> Запуск DAG & Обзор -> Экземпляры задач

И удалив все записи, относящиеся кdag id.

Однако следует отметить, что для отображения изменений в полях задач и статуса группы доступности базы данных на главной странице может потребоваться некоторое время.