我有一个DAG,有三个任务正在完美地工作。每个任务都是python操作符,DAG运行良好,当函数在同一个文件中定义时,我可以查看它,但一旦我将函数移动到不同的文件,以使代码更清晰,并将相同的函数导入到DAG文件中,它说DAG似乎丢失了。当我使用Subdag操作符破坏代码时,也会发生同样的事情,该怎么办呢?可能是什么错误?
t1 = PythonOperator(
task_id='abcd',
provide_context=True,
python_callable=abcd.efgh,
dag=dag
)
发布于 2019-07-04 06:23:05
如果您还没有这样做,请尝试设置主DAG文件及其在气流'DAGS‘文件夹中的依赖关系,如下图所示。
然后,使用以下方法将所需文件从各自的依赖文件夹导入到主DAG文件中:
从dependencies_dag1导入文件
https://stackoverflow.com/questions/56886060
复制相似问题