Apache Airflow 2：如何向自定义传感器的模板字段传入非模板参数

问题根源 #

报错的核心原因是你在自定义MySensor的__init__初始化方法中，没有将传入的file参数赋值给实例属性self.file。
Airflow的模板字段渲染逻辑要求：所有声明在template_fields中的字段，必须对应算子实例的同名属性，Airflow执行任务前会先读取实例的该属性值，再判断是否需要做Jinja语法解析。你之前传Jinja模板能运行属于个例，本质是不符合自定义算子的规范要求的。

修复方案 #

你只需要完善自定义传感器的初始化逻辑即可，不需要额外调整模板字段的配置，Airflow的模板机制天然支持同时传入模板字符串和普通字符串：

1. 修正自定义传感器的代码

from airflow.sensors.base import BaseSensorOperator

class MySensor(BaseSensorOperator):
    # 保留你原有的模板字段声明即可
    template_fields = ("file",)
    
    def __init__(self, file, *args, **kwargs):
        # 新增：将传入的file参数赋值给实例属性
        self.file = file
        # 必须调用父类的初始化方法，模板渲染等核心逻辑都由父类实现
        super().__init__(*args, **kwargs)
    
    def poke(self, context):
        # 你的传感器业务逻辑，直接调用self.file即可，Airflow已经自动完成了模板渲染（如果是Jinja字符串的话）
        # 示例逻辑：判断文件是否存在
        import os
        return os.path.exists(self.file)

2. 任务实例化的写法不需要修改，两种写法都可以正常运行：

• 传Jinja模板读取Airflow变量的写法：
  my_task = MySensor(task_id="my_task", file = "{{var.value.file}}")
• 直接传普通文件路径的写法：
  my_task = MySensor(task_id="my_task", file = "/my_test_file.jar")

补充说明 #

Airflow的模板字段机制对传入值的类型没有特殊限制，只要实例存在对应属性：如果传入的是包含Jinja语法的字符串，Airflow会自动渲染为最终值；如果传入的是普通字符串、数字等非模板内容，Airflow会直接保留原值使用，不需要额外配置。

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