| :py:mod:`airflow.sensors.time_sensor` |
| ===================================== |
| |
| .. py:module:: airflow.sensors.time_sensor |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.sensors.time_sensor.TimeSensor |
| airflow.sensors.time_sensor.TimeSensorAsync |
| |
| |
| |
| |
| .. py:class:: TimeSensor(*, target_time, **kwargs) |
| |
| Bases: :py:obj:`airflow.sensors.base.BaseSensorOperator` |
| |
| Waits until the specified time of the day. |
| |
| :param target_time: time after which the job succeeds |
| :type target_time: datetime.time |
| |
| .. py:method:: poke(self, context) |
| |
| Function that the sensors defined while deriving this class should |
| override. |
| |
| |
| |
| .. py:class:: TimeSensorAsync(*, target_time, **kwargs) |
| |
| Bases: :py:obj:`airflow.sensors.base.BaseSensorOperator` |
| |
| Waits until the specified time of the day, freeing up a worker slot while |
| it is waiting. |
| |
| :param target_time: time after which the job succeeds |
| :type target_time: datetime.time |
| |
| .. py:method:: execute(self, context) |
| |
| This is the main method to derive when creating an operator. |
| Context is the same dictionary used as when rendering jinja templates. |
| |
| Refer to get_template_context for more context. |
| |
| |
| .. py:method:: execute_complete(self, context, event=None) |
| |
| Callback for when the trigger fires - returns immediately. |
| |
| |
| |