airflow.providers.sftp.decorators.sensors.sftp

Module Contents

Functions

sftp_sensor_task([python_callable])

Wrap a function into an Airflow operator.
airflow.providers.sftp.decorators.sensors.sftp.sftp_sensor_task(python_callable=None, **kwargs)[source]

Wrap a function into an Airflow operator.

Accepts kwargs for operator kwarg. Can be reused in a single DAG. :param python_callable: Function to decorate

Was this entry helpful?