基本上,我试图从airflow中的另一个文件调用一个函数。我想使用airflow-docker从不同的文件运行一个python函数
我使用这个图像:https://airflow.apache.org/docs/apache-airflow/2.3.1/docker-compose.yaml运行气流
当我在同一个dag文件中运行一个函数时,一切都运行得很顺利。
但是,当我去我的localhost气流用户界面,我得到这样的错误(没有模块名称包括)
我已经在环境卷下面的docker-compose.yaml(includes)文件中添加了一行代码:
但我还是发现了同样的错误。
我能做些什么来修复这个错误吗?
如有任何帮助,我们将不胜感激。谢谢!
2条答案
按热度按时间pgpifvop1#
默认情况下,Airflow会在PYTHONPATH中添加插件和配置文件夹。
若要添加其他文件夹,需要显式设置它们
dgiusagp2#
无需修改
PYTHONPATH
环境变量或更改airflow.cfg
配置文件,您可以通过修改volumes部分来更新docker-compose.yaml
文件,如下所示:这会将主机上的
./includes
目录挂载到容器中的/opt/airflow/plugins/includes
目录,使您的自定义模块可用于Airflow,而无需修改任何其他配置文件或环境变量。