blob: 6b7352505d259a62444509cbfdfe7134f3e2aada [file] [log] [blame]
:mod:`airflow.providers.apache.hdfs.sensors.web_hdfs`
=====================================================
.. py:module:: airflow.providers.apache.hdfs.sensors.web_hdfs
Module Contents
---------------
.. py:class:: WebHdfsSensor(*, filepath: str, webhdfs_conn_id: str = 'webhdfs_default', **kwargs)
Bases: :class:`airflow.sensors.base.BaseSensorOperator`
Waits for a file or folder to land in HDFS
.. attribute:: template_fields
:annotation: = ['filepath']
.. method:: poke(self, context: Dict[Any, Any])