Airflow中Jinja将整数字符串列表渲染为整数元组问题排查

问题1：渲染结果变成元组而非字符串 #

根源在于你开启了render_template_as_native_obj=True，这个参数会让Airflow自动将Jinja模板渲染的结果转换为Python原生对象。当join(",")生成字符串"1,2,3"后，Airflow会把这个逗号分隔的字符串解析为整数元组(1,2,3)。

修复方案：

• 方案A：关闭原生对象转换（推荐，若无需全局该特性）
  移除DAG定义中的render_template_as_native_obj=True参数，或设为False，这样模板渲染结果会保持字符串类型：

  with airflow.DAG(
    'example_dag',
    params={
        'array': ['1', '2', '3'],
    },
  ) as dag:
  

• 方案B：强制保留字符串类型
  若必须保留render_template_as_native_obj=True，使用Jinja的string()过滤器强制转换结果为字符串，避免被自动解析为元组：

  dummy_job = job_operator.JobOperator(
      task_id='dummy_job',
      job_name='dummy_job',
      job_vars={
          'p': '{{ params.array | join(",") | string }}',
      },
  )
  

问题2：复杂Jinja表达式生成带大量空白的结果 #

你的表达式存在两个问题：

1. 模板中的换行和缩进被原样保留，导致渲染结果带多余空白；
2. 使用{% set p1 = p1.append(b) %}是错误的——append()方法返回None，会把p1覆盖为None，后续join操作无法执行（你能得到结果可能是代码笔误，实际循环的是params.array而非params.p）。

修复后的表达式：

使用{% do %}语句执行列表追加操作，同时去掉模板中的多余换行缩进：

'p': """{% set p1 = [] %}{% for b in params.array %}{% do p1.append(b) %}{% endfor %}{{ p1 | join(",") }}""",

若需要保留模板格式，可添加trim过滤器去除首尾空白：

'p': """
      {% set p1 = [] %}
      {% for b in params.array %}
          {% do p1.append(b) %}
      {% endfor %}
      {{ p1 | join(",") | trim }}""",

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