def METHOD_NAME(
    args,
    server_host,
    worker_hosts,
    num_workers,
    get_server_command,
    get_worker_command,
):
    """
    Same as `_run_ssh_cluster()` but running on event loop until completed.
    """
    try:
        asyncio.get_event_loop().run_until_complete(
            _run_ssh_cluster(
                args,
                server_host,
                worker_hosts,
                num_workers,
                get_server_command,
                get_worker_command,
            )
        )
    except (OSError, asyncssh.Error) as exc:
        sys.exit(f"SSH connection failed: {exc}")