astronomer.providers.microsoft.azure.triggers.wasb
==================================================

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


Classes
-------

.. autoapisummary::

   astronomer.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger
   astronomer.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger


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

.. py:class:: WasbBlobSensorTrigger(container_name, blob_name, wasb_conn_id = 'wasb_default', public_read = False, poke_interval = 5.0)

   Bases: :py:obj:`airflow.triggers.base.BaseTrigger`


   This class is deprecated and will be removed in 2.0.0.
   Use :class: `~airflow.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger` instead.


   .. py:attribute:: container_name


   .. py:attribute:: blob_name


   .. py:attribute:: wasb_conn_id


   .. py:attribute:: poke_interval


   .. py:attribute:: public_read


   .. py:method:: serialize()

      Serializes WasbBlobSensorTrigger arguments and classpath.



   .. py:method:: run()
      :async:


      Makes async connection to Azure WASB and polls for existence of the given blob name.



.. py:class:: WasbPrefixSensorTrigger(container_name, prefix, include = None, delimiter = '/', wasb_conn_id = 'wasb_default', public_read = False, poke_interval = 5.0)

   Bases: :py:obj:`airflow.triggers.base.BaseTrigger`


   This class is deprecated and will be removed in 2.0.0.
   Use :class: `~airflow.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger` instead.


   .. py:attribute:: container_name


   .. py:attribute:: prefix


   .. py:attribute:: include


   .. py:attribute:: delimiter


   .. py:attribute:: wasb_conn_id


   .. py:attribute:: poke_interval


   .. py:attribute:: public_read


   .. py:method:: serialize()

      Serializes WasbPrefixSensorTrigger arguments and classpath.



   .. py:method:: run()
      :async:


      Makes async connection to Azure WASB and polls for existence of a blob with given prefix.