airflow.sensors.time_delta

Module Contents

class airflow.sensors.time_delta.TimeDeltaSensor(*, delta, **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Waits for a timedelta after the run's data interval.

Parameters

delta (datetime.timedelta) -- time length to wait after the data interval before succeeding.

poke(self, context)[source]
class airflow.sensors.time_delta.TimeDeltaSensorAsync[source]

Bases: airflow.sensors.time_delta.TimeDeltaSensor

A drop-in replacement for TimeDeltaSensor that defers itself to avoid taking up a worker slot while it is waiting.

Parameters

delta (datetime.timedelta) -- time length to wait after the data interval before succeeding.

execute(self, context)[source]
execute_complete(self, context, event=None)[source]

Callback for when the trigger fires - returns immediately.

Was this entry helpful?