Воздушный поток - очистить все записи DAG из веб-интерфейса сразу для всех удаленных файлов DAG из папки dags_folder - PullRequest
0 голосов
/ 06 марта 2020

После удаления нескольких файлов DAG из папки dags необходимо запустить airflow delete_dag dag_id для каждой группы DAG или удалить записи DAG по одной из веб-интерфейса.

Вместо этого есть ли функциональность? или команда для очистки удаленных групп доступности базы данных в один go?

1 Ответ

2 голосов
/ 06 марта 2020

Вы всегда можете выполнить запросы к вашей базе данных Airflow напрямую; у нас есть процесс Airflow, который периодически очищает нашу базу данных, удаляя записи из log, task_fail и т. д. c.

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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...