astronomer.providers.microsoft.azure.triggers.data_factory

Module Contents

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.

class astronomer.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger(run_id, azure_data_factory_conn_id, poke_interval, resource_group_name, factory_name)

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.

serialize()

Serializes ADFPipelineRunStatusSensorTrigger arguments and classpath.

async run()

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)

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]

serialize()

Serializes AzureDataFactoryTrigger arguments and classpath.

async run()

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