Azure Data Factory Sensor Async¶
To checks the status of a pipeline run
AzureDataFactoryPipelineRunStatusSensorAsync
.
pipeline_run_sensor_async = AzureDataFactoryPipelineRunStatusSensorAsync(
task_id="pipeline_run_sensor_async",
run_id=cast(str, XComArg(run_pipeline_wait, key="run_id")),
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/microsoft/azure/example_dags/example_adf_run_pipeline.py