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