airflow.providers.sftp.sensors.sftp

This module contains SFTP sensor.

Module Contents

class airflow.providers.sftp.sensors.sftp.SFTPSensor(*, path: str, sftp_conn_id: str = '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 = ['path'][source]
poke(self, context: dict)[source]

Was this entry helpful?