阿帕奇气流问题 - "a task with task_id create_tag_template_field_result is already in the DAG"



所以,即使是空白的气流安装,我也有问题。

一旦我尝试运行

airflow test tutorial print_date 2015-06-01

我收到一个异常,上面写着

PendingDeprecationWarning:无法将请求的任务添加到DAG中,因为DAG中已存在task_id为create_tag_template_field_result的任务。从Airflow 2.0开始,尝试覆盖任务将引发异常

这是什么原因(因为我实际上没有对安装进行任何更改(?

在之前的一次安装中,我试图运行自己的dag。。。但是";create_tag_template_field_result";在我的代码中找不到。

您可以设置config arg load_examples=False来解决它。

这是测试命令将调用get_dag函数,该函数将构造一个DagBag对象,在构造函数中将调用collect_dag函数。当conf arg LOAD_EXAMPLES=True(默认为True(时,collect_dag函数将收集示例路径中的所有dag,这就是任务create_tag_template_field_result的来源
在collect_dgs函数中,将调用每个示例任务的add_task函数,在这里您将再次添加create_tag_template_field_result任务。也许这是一个快速启动,当你之前第一次在没有意识到的情况下添加这个任务时
您可以设置配置arg load_examples=False来解决

此警告发生在/usr/local/lib/python3.7/dist-packages/airflow/example_dgs/example_complex.py所以我删除或重命名(例如,为不工作的名称*.py.back(这个。

我在新安装时遇到了同样的错误。

然后我不知道这是否有帮助,但我将Airflow降级到1.10.10版本(使用python3.7(,错误就消失了。

最新更新