当尝试通过airflow trigger_dag test_dag运行dag时,我得到了错误:airflow.exceptions.DagNotFound: Dag id test_task not found运行airflow list_dags时,DAG正确列出。我还进行了检查,以确保将$AIRFLOW_HOME目录正确设置
我对气流很陌生,我试着运行一个引用风流v1.10.14中的自定义操作符(my_operators.py)的守护程序。问题:I在气流UI中得到以下错误:
Broken DAG: [/opt/airflow/dags/test_operator.py] No module named 'operators.my_operators“dag/operators/”目录下时