astronomer.providers.microsoft.azure.triggers.wasb

Classes

WasbBlobSensorTrigger

This class is deprecated and will be removed in 2.0.0.

WasbPrefixSensorTrigger

This class is deprecated and will be removed in 2.0.0.

Module Contents

class astronomer.providers.microsoft.azure.triggers.wasb.WasbBlobSensorTrigger(container_name, blob_name, wasb_conn_id='wasb_default', public_read=False, poke_interval=5.0)[source]

Bases: 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.

container_name
blob_name
wasb_conn_id
poke_interval
public_read
serialize()[source]

Serializes WasbBlobSensorTrigger arguments and classpath.

async run()[source]

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

class astronomer.providers.microsoft.azure.triggers.wasb.WasbPrefixSensorTrigger(container_name, prefix, include=None, delimiter='/', wasb_conn_id='wasb_default', public_read=False, poke_interval=5.0)[source]

Bases: 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.

container_name
prefix
include
delimiter
wasb_conn_id
poke_interval
public_read
serialize()[source]

Serializes WasbPrefixSensorTrigger arguments and classpath.

async run()[source]

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