小编bad*_*tal的帖子

我正在尝试将本地模块（python脚本）导入DAG。

目录结构：

airflow/
??? dag
?   ??? __init__.py
?   ??? my_DAG.py
??? script
    ??? subfolder
        ??? __init__.py
        ??? local_module.py

my_DAG.py中的示例代码：

#trying to import from local module
from script.subfolder import local_module  

#calling a function in local_module.py  
a = some_function()  

我在Airflow中收到一条错误消息，说“破损的DAG：my_DAG。没有名为“ local_module”的模块。

我已经将Airflow更新为1.9.0，但这不能解决问题。

• 这里有什么解决方案？
• 我还读了一些我可以通过创建插件来解决此问题的地方。谁能指出我该怎么做？

谢谢。