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
相关产品推荐
相关产品推荐

