airflow.contrib.sensors.ftp_sensor

Module Contents

class airflow.contrib.sensors.ftp_sensor.FTPSensor(path, ftp_conn_id='ftp_default', fail_on_transient_errors=True, *args, **kwargs)[source]

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Waits for a file or directory to be present on FTP.

template_fields = ['path'][source]

Errors that are transient in nature, and where action can be retried

transient_errors = [421, 425, 426, 434, 450, 451, 452][source]
error_code_pattern[source]
_create_hook(self)[source]

Return connection hook.

_get_error_code(self, e)[source]

Extract error code from ftp exception

poke(self, context)[source]
class airflow.contrib.sensors.ftp_sensor.FTPSSensor[source]

Bases: airflow.contrib.sensors.ftp_sensor.FTPSensor

Waits for a file or directory to be present on FTP over SSL.

_create_hook(self)[source]

Return connection hook.

Was this entry helpful?