咨询dag_run.conf含义、相关DAG代码逻辑及dag_run查阅渠道

代码整体作用 #

这段是Airflow的Jinja2模板代码，用于给dttm变量赋值，逻辑如下：

• 当DAG为自动调度运行（无手动传入配置）时，dttm取Airflow内置变量tomorrow_ds_nodash的值（格式为YYYYMMDD的明天日期）；
• 当手动触发DAG并传入自定义配置时，dttm取配置里的calc_date字段值，以此覆盖默认日期，实现指定日期的任务执行。

核心概念说明 #

• dag_run.conf：Airflow中存储手动触发DAG时传入的自定义配置的对象。自动调度的DAG运行无此配置，值为空；手动触发时，你可以传入JSON格式的键值对参数，这些参数都会被存在dag_run.conf里。
• dag_run.conf['calc_date']：从手动传入的配置中提取calc_date键对应的具体值，通常这个值是业务所需的日期字符串（比如YYYYMMDD格式），用来替代默认的tomorrow_ds_nodash，让任务按指定日期运行。

官方查阅渠道 #

Airflow官方文档的核心概念板块中，DagRun相关章节详细说明了dag_run对象的属性和用法，包括conf参数的定义与使用场景。你可以在Airflow官方文档内搜索DagRun或dag_run.conf找到对应内容。

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