Function wait_worker_online

scripts/install.py:650–678

(
    http_port: int, worker_id: str, api_key: str, plan: DeploymentPlan,
)

def wait_worker_online(
    http_port: int, worker_id: str, api_key: str, plan: DeploymentPlan,
) -> None:
    url = f"http://127.0.0.1:{http_port}/api/v1/workers?status=online&page=1&page_size=100"
    deadline = time.monotonic() + WORKER_ONLINE_TIMEOUT
    while time.monotonic() < deadline:
        try:
            result = api_request(url, api_key=api_key)
            workers = result.get("items") or []
            for w in workers:
                if w.get("node_id") == worker_id:
                    info("Worker is online!")
                    return
        except SystemExit:
            pass
        time.sleep(POLL_INTERVAL)

    if plan.worker_start == "systemd":
        hint = (
            f"  Check status:  systemctl status {plan.worker_service_name}\n"
            f"  Check logs:    journalctl -u {plan.worker_service_name} -n 200 --no-pager"
        )
    else:
        hint = "  Check the terminal output above for errors."

    fatal(
        "worker-online",
        f"Worker {worker_id} did not come online within {WORKER_ONLINE_TIMEOUT}s.\n{hint}",
    )


# ---------------------------------------------------------------------------