airflow - 气流将 jinja 模板传递给 dag 参数

Question

我正在尝试将 jinja 模板传递给 DAG 构造函数。正如气流最佳实践所建议的那样，不要在执行方法之外调用变量。

下面是代码片段。

 dag = DAG(
        dag_id=dag_id,
        schedule_interval=schedule_interval,
        dagrun_timeout=timedelta(hours=max_dagrun),
        template_searchpath='{{var.value.sql_path}}')

但它无法解析这一点。

任何建议如何传递这些类型的变量？这些被传递给 dag 而不是气流操作员。

提前致谢。

标签： airflow