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?