You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Airflow调度触发DAG时dag_run.conf为None的问题求助

Airflow调度触发DAG时dag_run.conf为None的问题求助

各位好,我目前在使用Airflow运行一个DAG,想要让它按照设定的调度规则自动执行,但碰到了一个棘手的问题:当DAG由调度器自动触发时,dag_run.conf的结果总是None,完全不符合预期。

我之前尝试过一种给dag_run.conf设置默认值的方案,但对我的情况没有效果。

我的代码大概是这样的:

def parse_conf(**kwargs):
    print(f"dag run config is {dag_run.conf}")  # 调度器触发时这里打印的是None

with DAG(
    # 这里省略了DAG的其他配置项
    schedule_interval="* * * * *",
    params={
        "test_param": "test",
    },
) as dag:

    config_task = PythonOperator(task_id="parse_config", python_callable=parse_conf)
    # 省略其他任务逻辑
    start_task.set_downstream(config_task)

如果是手动触发这个DAG的话,config的取值完全是正常的。另外,我已经在Airflow的配置文件里把dag_run_conf_overrides_params设置为True了,还是没解决问题。

备注:内容来源于stack exchange,提问作者boston-hacker

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.17 08:14:29