时间戳

首页 > 解决方案 > 自定义挂钩的 Airflow 2.0.1/Python 3.7.9 ModuleNotFoundError

python - 自定义挂钩的 Airflow 2.0.1/Python 3.7.9 ModuleNotFoundError

问题描述

我的原生气流构建中的结构如下

dags/cust_dag.py dags/jhook.py --包含类UtilTriggers，其下有多个方法

在 cust_dag 代码中，我将该钩子/模块称为：

从 jhook 导入 UtilTriggers 作为触发器

当我检查 Airflow UI 时，我因为 cust_dag 提到错误为 ModuleNotFoundError: No module named jhook

相同类型的代码正在 composer 1.9 上运行，目前我在本机气流上运行它。

此外，我尝试添加init .py 文件并创建了一个新文件夹 job_trigger，我在该文件夹下添加了该文件仍然无法正常工作。

我已经尝试过这个问题中提到的解决方案Apache Airflow DAG cannot import local module

即在钩子自定义模块和dag文件中添加下面的代码行 import sys sys.path.insert(0,os.path.abspath(os.path.dirname( file )))

当一切正常时，请指导我导致此 ModuleNotFound 错误的原因。

标签： pythonmoduleairflowgoogle-cloud-composer

解决方案

推荐阅读