astronomer.providers.microsoft.azure.triggers.data_factory

Classes

ADFPipelineRunStatusSensorTrigger

This class is deprecated and will be removed in 2.0.0.

AzureDataFactoryTrigger

This class is deprecated and will be removed in 2.0.0.

Module Contents

class astronomer.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger(run_id, azure_data_factory_conn_id, poke_interval, resource_group_name, factory_name)[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.data_factory.ADFPipelineRunStatusSensorTrigger instead.

run_id
azure_data_factory_conn_id
resource_group_name
factory_name
poke_interval
serialize()[source]

Serializes ADFPipelineRunStatusSensorTrigger arguments and classpath.

async run()[source]

Make async connection to Azure Data Factory, polls for the pipeline run status

class astronomer.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger(run_id, azure_data_factory_conn_id, end_time, resource_group_name, factory_name, wait_for_termination=True, check_interval=60)[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.data_factory.AzureDataFactoryTrigger instead.

QUEUED = 'Queued'
IN_PROGRESS = 'InProgress'
SUCCEEDED = 'Succeeded'
FAILED = 'Failed'
CANCELING = 'Canceling'
CANCELLED = 'Cancelled'
INTERMEDIATE_STATES: List[str]
FAILURE_STATES: List[str]
SUCCESS_STATES: List[str]
TERMINAL_STATUSES: List[str]
azure_data_factory_conn_id
check_interval
run_id
wait_for_termination
resource_group_name
factory_name
end_time
serialize()[source]

Serializes AzureDataFactoryTrigger arguments and classpath.

async run()[source]

Make async connection to Azure Data Factory, polls for the pipeline run status