2

in airflow show information about Broken DAG

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

I tried to move file with DAG copy_from_Oracle_to_MySQL.py from /data/airflow/dags.

But airflow showing information 

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

What I must to do that information about Broken DAG clean from GUI?

Nikolay Baranenko
  • 1,380
  • 4
  • 25
  • 54
  • To those finding answers, please refer to https://stackoverflow.com/a/49375328/1776759 – SMDC Mar 20 '18 at 02:26

2 Answers2

2

So removing the DAG file won't clean them all, you will need to delete all dag_id in your metadata DB then UI won't show them, you can find a list of tables here: https://issues.apache.org/jira/browse/AIRFLOW-1002.

Chengzhi
  • 2,373
  • 2
  • 22
  • 38
0

Where did you place Oracle_to_MySQL_plugin? Did you check is it in your pythonpath?

AlessioG
  • 526
  • 3
  • 12
  • 31