Как удалить поврежденный DAG из списка воздушных потоков?
В потоке воздуха показать информацию о Broken DAG
Broken DAG: [/data/airflow/dags/copy_from_Oracle_to_MySQL.py] No module named Oracle_to_MySQL_plugin
Я попытался переместить файл с помощью DAG copy_from_Oracle_to_MySQL.py из /data/airflow/dags.
Но воздушный поток показывает информацию
Broken DAG: [/data/airflow/dags/copy_from_Oracle_to_MySQL.py] No module named Oracle_to_MySQL_plugin
Что я должен сделать, чтобы информация о Broken DAG очищалась от GUI?
2 ответа
Решение
Таким образом, удаление файла DAG не очистит их все, вам нужно удалить все dag_id в вашей БД метаданных, тогда пользовательский интерфейс не будет их отображать, вы можете найти список таблиц здесь: https://issues.apache.org/jira/browse/AIRFLOW-1002.
Где вы разместили Oracle_to_MySQL_plugin? Вы проверили это в вашем pythonpath?