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

External Deployment Task Sensor Async

To check for the deployment state by making a HTTP GET request async ExternalDeploymentTaskSensorAsync.

external_deployment_task = ExternalDeploymentTaskSensorAsync(
    task_id="external_deployment_task",
    http_conn_id=DEPLOYMENT_CONN_ID,
    endpoint=f"/api/v1/dags/{DAG_ID}/dagRuns/{RUN_ID}/taskInstances/{TASK_ID}",
    headers=generate_header_access_token.output,
    poke_interval=5,
)
# https://github.com/astronomer/astronomer-providers/tree/main/astronomer/providers/core/example_dags/example_external_deployment_task_sensor.py