`airflow.sensors.time_delta`¶

Module Contents¶

`TimeDeltaSensor`	Waits for a timedelta after the run's data interval.
`TimeDeltaSensorAsync`	A drop-in replacement for TimeDeltaSensor that defers itself to avoid

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

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]¶: Function that the sensors defined while deriving this class should override.

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

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]¶

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

execute_complete(self, context, event=None)[source]¶: Callback for when the trigger fires - returns immediately.