`airflow.sensors.time_delta_sensor`¶

Module Contents¶

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

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Waits for a timedelta after the task’s execution_date + schedule_interval. In Airflow, the daily task stamped with execution_date 2016-01-01 can only start running on 2016-01-02. The timedelta here represents the time after the execution period has closed.

Parameters: delta (datetime.timedelta) – time length to wait after execution_date before succeeding

poke(self, context)[source]¶

Was this entry helpful?