如何解决Airflow 2.3.3中ModuleNotFoundError: No module named 'utilities'错误？

1. 确认Airflow运行环境的Python路径 #

Airflow常使用独立Python环境（虚拟环境、容器环境等），你安装的包可能不在Airflow调用的环境里：

• 执行airflow info查看Airflow关联的Python解释器路径（对应输出里的Python Version项）
• 用该路径的pip重新安装包：/path/to/airflow/python -m pip install utilities-package

2. 排查本地模块的导入路径 #

如果utilities是自定义本地模块而非PyPI公共包：

• 在DA.py开头添加代码，将模块所在目录加入Python路径：

  import sys
  sys.path.append("/path/to/folder-containing-utilities")
  

• 或者直接把utilities目录放到Airflow的dags目录下，Airflow会自动识别该路径

3. 验证包的安装状态 #

在Airflow使用的Python环境中执行以下代码，确认包是否真的安装成功：

import utilities
print(utilities.__file__)

能正常导入并打印模块路径则说明安装有效；若仍报错，说明包未安装到正确环境。

4. 分布式部署下检查Worker环境 #

如果是多Worker的Airflow集群，需确保所有Worker节点的Python环境都安装了该包，且模块路径一致。

内容的提问来源于stack exchange，提问作者saharsha baral