如何从气流列表中删除破损的DAG



在气流中显示有关损坏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移动文件

但流量显示信息

Broken DAG: [/data/airflow/dags/copy_from_Oracle_to_MySQL.py] No module named Oracle_to_MySQL_plugin

我必须做什么才能从GUI中进行有关破碎的DAG的信息?

因此,删除DAG文件不会全部清洁它们,您需要删除元数据DB中的所有DAG_ID,然后UI不会显示它们,您可以在此处找到表格列表:https://issues.apache.org/jira/browse/airflow-1002。

您在哪里放置了oracle_to_mysql_plugin?您是否在PythonPath中检查了吗?

最新更新