Azure Data Factory Operator Async¶
To executes a data factory pipeline asynchronously
AzureDataFactoryRunPipelineOperatorAsync
.
# This task uses azure_data_factory_default connection
run_pipeline_wait = AzureDataFactoryRunPipelineOperatorAsync(
task_id="run_pipeline_wait",
pipeline_name=PIPELINE_NAME,
factory_name=DATAFACTORY_NAME,
resource_group_name=RESOURCE_GROUP_NAME,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/microsoft/azure/example_dags/example_adf_run_pipeline.py