astronomer.providers.sftp.triggers.sftp

Classes

SFTPTrigger

This class is deprecated and will be removed in 2.0.0.

Module Contents

class astronomer.providers.sftp.triggers.sftp.SFTPTrigger(path, file_pattern='', sftp_conn_id='sftp_default', newer_than=None, poke_interval=5)[source]

Bases: airflow.triggers.base.BaseTrigger

This class is deprecated and will be removed in 2.0.0. Use :class: ~airflow.providers.sftp.triggers.sftp.SFTPTrigger instead.

path
file_pattern
sftp_conn_id
newer_than
poke_interval
serialize()[source]

Serializes SFTPTrigger arguments and classpath

async run()[source]

Makes a series of asynchronous calls to sftp servers via async sftp hook. It yields a Trigger

  • If file matching file pattern exists at the specified path return it,

  • If file pattern was not provided, it looks directly into the specific path which was provided.

  • If newer then datetime was provided it looks for the file path last modified time and check whether the last modified time is greater, if true return file if false it polls again.