Airflow中dag.test()是否写入元数据库？本地调试安全性咨询

我在PyCharm中使用Airflow 2.9.1的dag.test()方法调试DAG。多次运行后环境出现异常（如DAG指向的某端点被多次调用，疑因重试），不确定是否因dag.test()写入Airflow元数据库所致。

多次启动DAG后，无法执行特定任务，出现如下错误：

{dag.py:2923} WARNING - No tasks to run. unrunnable tasks:
{<TaskInstance: dags-np-flow.split_payload manual__2025-09-23T10:27:22.745934+00:00 [None]>,
<TaskInstance: dags-np-flow.filter_dm_ok manual__2025-09-23T10:27:22.745934+00:00 [None]>,
<TaskInstance: dags-np-flow.fetch_triggered_dag_xcom manual__2025-09-23T10:27:22.745934+00:00 [None]>,
<TaskInstance: dags-np-flow.recall_step manual__2025-09-23T10:27:22.745934+00:00 [None]>,
<TaskInstance: dags-np-flow.recall_dm_step manual__2025-09-23T10:27:22.745934+00:00 [running]>}

最初通过airflow tasks clear dags-to-run --yes解决，但后来不得不执行airflow db reset才能重新运行。

现咨询：

1. dag.test()是否会在元数据库中创建DAG运行记录、任务实例或XCom？我原以为它仅使用本地资源。
2. 在开发环境中重复使用dag.test()是否安全，还是应选择其他本地调试方式？

问题1：dag.test()是否会写入元数据库？ #

默认情况下，dag.test()不会写入Airflow元数据库。它是专为本地调试设计的工具，会在内存中模拟任务执行流程，不会将DAG运行记录、任务实例或XCom持久化到元数据库中。

例外情况：如果任务代码中存在显式操作元数据库的逻辑（比如手动写入XCom、更新任务状态），或者调试时传入的参数触发了持久化行为，才可能产生元数据写入。Airflow 2.9.1版本默认无此问题，但需排查任务自身的代码逻辑。

你遇到的端点重复调用问题，更可能是任务自身的重试机制触发（比如任务执行失败后自动重试），而非元数据库残留记录导致的重复执行。

问题2：开发环境重复使用dag.test()是否安全？ #

在开发环境中重复使用dag.test()是相对安全的，但需注意以下事项：

• 隔离元数据库操作：如果任务包含手动操作元数据的代码，调试时建议临时注释或改用内存型元数据库（如SQLite内存模式），避免污染正式元数据。
• 清理任务状态：出现任务状态异常时，优先使用airflow tasks clear <dag_id> --yes清理指定DAG的任务实例状态，无需直接重置整个数据库。
• 备选调试方案：
  • 使用airflow tasks test <dag_id> <task_id> <execution_date>：单独测试单个任务，轻量化且默认不写入元数据库。
  • 启用调试模式：在airflow.cfg中设置debug_mode = True，减少不必要的持久化操作。
  • 编写单元测试：针对DAG和任务逻辑编写单元测试，完全脱离Airflow运行环境，彻底避免环境污染。

内容的提问来源于stack exchange，提问作者Nauel