gpt4 book ai didi

Airflow 运算符(operator)导入似乎不起作用

转载 作者:行者123 更新时间:2023-12-05 01:08:58 25 4
gpt4 key购买 nike

我是 Airflow 新手,需要一些指导...我正在创建我的第一个使用 subdag 并导入 subdag 运算符的 dag

`from airflow.operators.subdag import SubDagOperator`

但是我不断收到流动错误“损坏的 DAG:[/usr/local/airflow/dags/POC_Main_DAG.py] 没有名为 'airflow.operators.subdag' 的模块”

我也尝试导入虚拟运算符 ang 得到了同样的错误。另一方面,以下运算符似乎按预期导入。

from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from airflow.operators.mysql_operator import MySqlOperator

感谢有关解决此问题的帮助提前致谢!

最佳答案

您使用的是什么版本的 Airflow?

如果您使用的是 Airflow 1.10.x,请使用以下内容:

from airflow.operators.subdag_operator import SubDagOperator

from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator

在 Airflow >=2.0.0 中,使用以下内容:

from airflow.operators.subdag import SubDagOperator

from airflow.operators.bash import BashOperator
from airflow.operators.python import PythonOperator

关于 Airflow 运算符(operator)导入似乎不起作用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65583550/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com