airflow.sensors.time_delta

模块内容

类

TimeDeltaSensor

在运行的数据间隔之后等待一段时间。

TimeDeltaSensorAsync

TimeDeltaSensor 的可延期替代品。
class airflow.sensors.time_delta.TimeDeltaSensor(*, delta, **kwargs)[source]

基类: airflow.sensors.base.BaseSensorOperator

在运行的数据间隔之后等待一段时间。

参数

delta – 成功前在数据间隔之后等待的时间长度。

另请参阅

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

poke(context)[source]

派生此类时覆盖。

class airflow.sensors.time_delta.TimeDeltaSensorAsync(*, end_from_trigger=False, delta, **kwargs)[source]

基类: TimeDeltaSensor

TimeDeltaSensor 的可延期替代品。

将自身延期以避免在等待时占用工作进程插槽。

参数

  • delta – 成功前在数据间隔之后等待的时间长度。

  • end_from_trigger (bool) – 直接从触发器结束任务，而不进入工作进程。

另请参阅

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

execute(context)[source]

在创建运算符时派生。

上下文是与呈现 Jinja 模板时使用的相同字典。

有关更多上下文，请参阅 get_template_context。

execute_complete(context, event=None)[source]

处理触发器触发时返回的事件，并立即返回。

此条目是否有帮助？