`airflow.contrib.sensors.sftp_sensor`¶

Module Contents¶

class airflow.contrib.sensors.sftp_sensor.SFTPSensor(path, sftp_conn_id='sftp_default', *args, **kwargs)[source]¶

Bases: airflow.operators.sensors.BaseSensorOperator

Waits for a file or directory to be present on SFTP.

Parameters

path (str) – Remote file or directory path
sftp_conn_id (str) – The connection to run the sensor against

template_fields = ['path'][source]¶

poke(self, context)[source]¶

Was this entry helpful?