`airflow.providers.microsoft.azure.triggers.data_factory`¶

Module Contents¶

Classes¶

`ADFPipelineRunStatusSensorTrigger`	ADFPipelineRunStatusSensorTrigger is fired as deferred class with params to run the
`AzureDataFactoryTrigger`	AzureDataFactoryTrigger is triggered when Azure data factory pipeline job succeeded or failed.

class airflow.providers.microsoft.azure.triggers.data_factory.ADFPipelineRunStatusSensorTrigger(run_id, azure_data_factory_conn_id, poke_interval, resource_group_name=None, factory_name=None)[source]¶

Bases: airflow.triggers.base.BaseTrigger

ADFPipelineRunStatusSensorTrigger is fired as deferred class with params to run the task in trigger worker, when ADF Pipeline is running

Parameters

run_id (str) – The pipeline run identifier.
azure_data_factory_conn_id (str) – The connection identifier for connecting to Azure Data Factory.
poke_interval (float) – polling period in seconds to check for the status
resource_group_name (str | None) – The resource group name.
factory_name (str | None) – The data factory name.

serialize()[source]¶

Serializes ADFPipelineRunStatusSensorTrigger arguments and classpath.

async run()[source]¶

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

class airflow.providers.microsoft.azure.triggers.data_factory.AzureDataFactoryTrigger(run_id, azure_data_factory_conn_id, end_time, resource_group_name=None, factory_name=None, wait_for_termination=True, check_interval=60)[source]¶