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

Question

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

只要我试着跑

airflow test tutorial print_date 2015-06-01

我收到一个引发的异常，上面写着

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

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

在之前的安装中，当我尝试运行自己的 dag 时，我也遇到了这个问题……但是在我的代码中找不到“create_tag_template_field_result”。

Answer 1

您可以设置配置参数 load_examples = False 来解决它。

这是测试命令，会调用get_dag函数，该函数会构造一个DagBag对象，在构造函数中会调用collect_dags函数。当配置参数 LOAD_EXAMPLES=True(default True) 时，collect_dags 函数将收集示例路径中的所有 dags，这就是任务 create_tag_template_field_result 的来源。
并且在collect_dags函数中将调用每个示例任务的add_task函数，这就是您再次添加create_tag_template_field_result任务的地方。也许当你第一次添加这个任务时你并没有意识到它是快速启动的。
您可以设置配置参数 load_examples = False 来解决它