airflow.contrib.sensors.sftp_sensor

Module Contents

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

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']

poke(self, context)