:py:mod:`astronomer.providers.microsoft.azure.sensors.wasb`
===========================================================

.. py:module:: astronomer.providers.microsoft.azure.sensors.wasb


Module Contents
---------------

Classes
~~~~~~~

.. autoapisummary::

   astronomer.providers.microsoft.azure.sensors.wasb.WasbBlobSensorAsync
   astronomer.providers.microsoft.azure.sensors.wasb.WasbPrefixSensorAsync




.. py:class:: WasbBlobSensorAsync(*, container_name, blob_name, wasb_conn_id = 'wasb_default', public_read = False, poll_interval = 5.0, **kwargs)

   Bases: :py:obj:`airflow.providers.microsoft.azure.sensors.wasb.WasbBlobSensor`

   Polls asynchronously for the existence of a blob in a WASB container.

   :param container_name: name of the container in which the blob should be searched for
   :param blob_name: name of the blob to check existence for
   :param wasb_conn_id: the connection identifier for connecting to Azure WASB
   :param poll_interval:  polling period in seconds to check for the status
   :param public_read: whether an anonymous public read access should be used. Default is False

   .. py:method:: execute(context)

      Defers trigger class to poll for state of the job run until it reaches a failure state or success state


   .. py:method:: execute_complete(context, event)

      Callback for when the trigger fires - returns immediately.
      Relies on trigger to throw an exception, otherwise it assumes execution was
      successful.



.. py:class:: WasbPrefixSensorAsync(*, container_name, prefix, include = None, delimiter = '/', wasb_conn_id = 'wasb_default', public_read = False, poll_interval = 5.0, **kwargs)

   Bases: :py:obj:`airflow.providers.microsoft.azure.sensors.wasb.WasbPrefixSensor`

    Polls asynchronously for the existence of a blob having the given prefix in a WASB container.

   :param container_name: name of the container in which the blob should be searched for
   :param blob_name: name of the blob to check existence for
   :param include: specifies one or more additional datasets to include in the
           response. Options include: ``snapshots``, ``metadata``, ``uncommittedblobs``,
           ``copy`, ``deleted``
   :param delimiter: filters objects based on the delimiter (for e.g '.csv')
   :param wasb_conn_id: the connection identifier for connecting to Azure WASB
   :param poll_interval:  polling period in seconds to check for the status
   :param public_read: whether an anonymous public read access should be used. Default is False

   .. py:method:: execute(context)

      Defers trigger class to poll for state of the job run until it reaches a failure state or success state


   .. py:method:: execute_complete(context, event)

      Callback for when the trigger fires - returns immediately.
      Relies on trigger to throw an exception, otherwise it assumes execution was
      successful.