data/src/common/aca.py — start_and_wait()
27def azure_token(scope=MANAGEMENT_SCOPE) -> str:
40 return DefaultAzureCredential().get_token(scope).token
41
62 base = f"https://management.azure.com/subscriptions/{subscription}…"
68 request = urllib.request.Request(f"{base}/start?api-version=…", …)
73 execution = started.get("name", "")
77 while time.monotonic() < deadline:
80 request = … f"{base}/executions?api-version=…"
85 current = next(run for run in executions if run["name"] == execution)
88 if status == SUCCEEDED: return execution
💡 Hover or tap blue lines. No `az` CLI on the Airflow VM — plain HTTP + identity token.