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

How delete broken DAG from airflow list?

在 airflow 中显示有关 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

关于从 GUI 清除 Broken DAG 的信息,我必须做什么?

所以删除 DAG 文件不会全部清除它们,您需要删除元数据数据库中的所有 dag_id 然后 UI 将不会显示它们,您可以找到一个列表此处的表格:https://issues.apache.org/jira/browse/AIRFLOW-1002.

你把Oracle_to_MySQL_plugin放在哪里了?你检查过它在你的 pythonpath 中吗?