我正在尝试在连接到我的 Google Cloud Platform 帐户的本地气流环境中运行 DAG,因此我能够创建新的 GCP 虚拟机实例并将它们配置为按计划的时间间隔处理来自暂存区域的文件。作为其中的一部分,我必须使用自定义操作符,它继承了标准气流操作符的属性。当我导入第一个自定义运算符并运行我的 DAG 时,它运行良好,但是,如果我尝试导入更多自定义运算符,那么我的 DAG 会失败并给出带有错误消息的下图。
如果有人可以帮助我确定这里可能出现的问题并分享任何有用的提示或要进行的检查,我将不胜感激!
____/ ( ( ) ) \___
/( ( ( ) _ )) ) )\
(( ( )( ) ) ( ) )
((/ ( _( ) ( _) ) ( () ) )
( ( ( (_) (( ( ) .((_ ) . )_
( ( ) ( ( ) ) ) . ) ( )
( ( ( ( ) ( _ ( _) ). ) …
Run Code Online (Sandbox Code Playgroud) airflow ×1