`airflow.sensors.python`¶

模块内容¶

等待 Python 可调用对象返回 True。

class airflow.sensors.python.PythonSensor(*, python_callable, op_args=None, op_kwargs=None, templates_dict=None, **kwargs)[源代码]¶

等待 Python 可调用对象返回 True。

用户可以在 templates_dict 中放入输入参数，例如 templates_dict = {'start_ds': 1970}，并通过在可调用对象中调用 kwargs['templates_dict']['start_ds'] 来访问参数

参数

python_callable (Callable) – 对可调用对象的引用
op_kwargs (Mapping[str, Any] | None) – 一个字典，其中包含将在函数中解包的关键字参数
op_args (list | None) – 一个位置参数列表，在调用可调用对象时会被解包
templates_dict (dict | None) – 一个字典，其中的值是模板，这些模板将在 __init__ 和 execute 之间由 Airflow 引擎进行模板化，并在模板应用后在可调用对象的上下文中可用。

另请参阅

有关如何使用此传感器的更多信息，请查看指南：PythonSensor

template_fields: Sequence[str] = ('templates_dict', 'op_args', 'op_kwargs')[源代码]¶

poke(context)[源代码]¶

在派生此类时重写。