airflow.providers.standard.sensors.time_delta¶
Classes¶
Waits for a timedelta. |
|
Deprecated. Use TimeDeltaSensor with deferrable=True instead. |
|
A sensor that waits a specified period of time before completing. |
Module Contents¶
- class airflow.providers.standard.sensors.time_delta.TimeDeltaSensor(*, delta, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), end_from_trigger=False, **kwargs)[source]¶
Bases:
airflow.sensors.base.BaseSensorOperator
Waits for a timedelta.
The delta will be evaluated against data_interval_end if present for the dag run, otherwise run_after will be used.
- Parameters:
delta (datetime.timedelta) – time to wait before succeeding.
deferrable (bool) – Run sensor in deferrable mode. If set to True, task will defer itself to avoid taking up a worker slot while it is waiting.
See also
For more information on how to use this sensor, take a look at the guide: TimeDeltaSensor
- class airflow.providers.standard.sensors.time_delta.TimeDeltaSensorAsync(*, end_from_trigger=False, delta, **kwargs)[source]¶
Bases:
TimeDeltaSensor
Deprecated. Use TimeDeltaSensor with deferrable=True instead.
- Sphinx-autoapi-skip:
- class airflow.providers.standard.sensors.time_delta.WaitSensor(time_to_wait, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), **kwargs)[source]¶
Bases:
airflow.sensors.base.BaseSensorOperator
A sensor that waits a specified period of time before completing.
This differs from TimeDeltaSensor because the time to wait is measured from the start of the task, not the data_interval_end of the DAG run.
- Parameters:
time_to_wait (datetime.timedelta | int) – time length to wait after the task starts before succeeding.
deferrable (bool) – Run sensor in deferrable mode