`airflow.sensors.time_sensor`¶

Module Contents¶

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

poke(self, context)[source]¶

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

Bases: airflow.sensors.base.BaseSensorOperator

Waits until the specified time of the day, freeing up a worker slot while it is waiting.

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

execute(self, context)[source]¶

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

Was this entry helpful?