如何在bash终端执行airflow test时设置dag_run.conf参数？

嘿，这个问题我之前踩过坑！其实你遇到的报错根源在于：传统的airflow test命令本身不支持传入dag_run.conf——因为它是用来孤立测试单个任务的，不会创建真正的DAG Run实例，自然也就没有dag_run对象可以挂载配置参数。不过别担心，有几个实用的解决方案：

方法1：用Airflow 2.x+推荐的airflow tasks test命令（最简便） #

如果你用的是Airflow 2.x及以上版本，直接用airflow tasks test替代旧的airflow test，它支持--conf参数直接传入配置：

airflow tasks test example_trigger_target_dag run_this '2018-01-01' --conf '{"key": "your_value"}'

这个命令会在任务的上下文中注入模拟的dag_run.conf，完美解决你的测试需求。

方法2：旧版Airflow（1.x）的临时模拟方案 #

如果还在使用Airflow 1.x，没法用--conf参数的话，可以在任务代码里临时模拟dag_run.conf的值：
比如修改你的run_this任务函数：

def run_this_func(**context):
    # 临时添加测试用的conf，测试完成后记得移除
    if context.get('test_mode'):
        conf = {"key": "your_test_value"}
    else:
        conf = context['dag_run'].conf
    
    # 后续业务逻辑使用conf即可
    print(f"Received conf: {conf}")

修改完后再执行原来的命令：

airflow test example_trigger_target_dag run_this '2018-01-01'

方法3：模拟真实触发场景（适合复杂测试） #

如果你想完全模拟DAG被触发的真实场景，可以先手动创建带conf的DAG Run，再测试对应任务：

1. 触发DAG并传入conf：

airflow dags trigger example_trigger_target_dag --conf '{"key": "your_value"}'

2. 找到该DAG Run对应的任务实例ID，然后用airflow tasks run命令执行：

airflow tasks run example_trigger_target_dag run_this <execution_date> --local

这个方法更贴近生产环境的触发逻辑，但步骤相对繁琐。

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