:py:mod:`astronomer.providers.microsoft.azure.triggers.wasb` ============================================================ .. py:module:: astronomer.providers.microsoft.azure.triggers.wasb Module Contents --------------- Classes ~~~~~~~ .. autoapisummary:: astronomer.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger astronomer.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger .. 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: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: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.