airflow.sensors.web_hdfs_sensor

Module Contents

class airflow.sensors.web_hdfs_sensor.WebHdfsSensor(filepath, webhdfs_conn_id='webhdfs_default', *args, **kwargs)[source]

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Waits for a file or folder to land in HDFS

template_fields = ['filepath'][source]
poke(self, context)[source]

Was this entry helpful?