airflow.providers.sftp.sensors.sftp

This module contains SFTP sensor.

Module Contents

Classes

SFTPSensor

Waits for a file or directory to be present on SFTP.
class airflow.providers.sftp.sensors.sftp.SFTPSensor(*, path, sftp_conn_id='sftp_default', **kwargs)[source]

Bases: airflow.sensors.base.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 :Sequence[str] = ['path'][source]
poke(self, context)[source]

Function that the sensors defined while deriving this class should override.

Was this entry helpful?