External Task Sensor Async¶
To waits asynchronously for a external task to complete
ExternalTaskSensorAsync
.
waiting_for_task = ExternalTaskSensorAsync(
task_id="waiting_for_task",
external_task_id="wait_for_me",
external_dag_id="example_external_task",
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/core/example_dags/example_external_task.py