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