| |
| |
| :mod:`airflow.contrib.sensors.sftp_sensor` |
| ========================================== |
| |
| .. py:module:: airflow.contrib.sensors.sftp_sensor |
| |
| |
| |
| |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| |
| |
| |
| |
| |
| .. py:class:: SFTPSensor(path, sftp_conn_id='sftp_default', *args, **kwargs) |
| |
| Bases::class:`airflow.operators.sensors.BaseSensorOperator` |
| |
| |
| |
| Waits for a file or directory to be present on SFTP. |
| |
| :param path: Remote file or directory path |
| :type path: str |
| :param sftp_conn_id: The connection to run the sensor against |
| :type sftp_conn_id: str |
| |
| |
| |
| |
| |
| |
| .. attribute:: template_fields |
| :annotation: = ['path'] |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| .. method:: poke(self, context) |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
