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]

Was this entry helpful?