`airflow.sensors.time_sensor`¶

Module Contents¶

Classes¶

`TimeSensor`	Waits until the specified time of the day.
`TimeSensorAsync`	Waits until the specified time of the day.

class airflow.sensors.time_sensor.TimeSensor(*, target_time, **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Waits until the specified time of the day.

Parameters: target_time (datetime.time) – time after which the job succeeds

See also

For more information on how to use this sensor, take a look at the guide: TimeSensor

poke(context)[source]¶

Override when deriving this class.

class airflow.sensors.time_sensor.TimeSensorAsync(*, target_time, **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Waits until the specified time of the day.

This frees up a worker slot while it is waiting.

Parameters: target_time (datetime.time) – time after which the job succeeds

See also

For more information on how to use this sensor, take a look at the guide: TimeSensorAsync

execute(context)[source]¶

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(context, event=None)[source]¶

Execute when the trigger fires - returns immediately.

Was this entry helpful?