气流从 UI 手动运行传递配置答案

【问题标题】：Airflow to pass config from UI manual run气流从 UI 手动运行传递配置
【发布时间】：2021-06-21 18:43:05
【问题描述】：

有没有办法将 JSON 配置从手动 DAG 运行（从 dag_run.conf['attribute'] 传递到 KubernetesPodOperator？

尝试在 YAML 的模板化字段上使用 Jinja 模板，但出现错误，dag_run is not defined。

task_parse_raw_data = KubernetesPodOperator(
        namespace=NAMESPACE, 
        image='artifactory/image:tag',
        service_account_name='airflow',
        cmds=["sh", "/current.sh"],
        arguments=[ {{ dag_run.conf['date']}} ],
        ...)

【问题讨论】：

标签： kubernetes airflow

【解决方案1】：

您需要将 Jinja 表达式用引号括起来，如下所示：

arguments=[ "{{ dag_run.conf['date'] }}" ]

【讨论】：

谢谢！这有帮助！