Apache Airflow问题-“ DAG中已经有一个具有task_id create_tag_template_field_result的任务”

问题描述

所以，即使是空白的Airflow安装，我也有问题。

我尝试运行

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_dags函数。 当conf arg LOAD_EXAMPLES = True（默认为True）时，collect_dags函数将收集示例路径中的所有dag，这就是任务create_tag_template_field_result的来源。
并且在collect_dags函数中将调用每个示例任务的add_task函数，在这里您可以再次添加create_tag_template_field_result任务。 也许这是快速入门，当您第一次没有意识到时就添加了此任务。
您可以设置config arg load_examples = False来解决

,

此警告发生在 /usr/local/lib/python3.7/dist-packages/airflow/example_dags/example_complex.py 所以我删除或重命名（例如，将其重命名为* .py.back）。

,

重新安装时出现相同的错误。

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