async def METHOD_NAME(app: FastAPI, cluster: Cluster) -> Cluster:
    await utils_docker.remove_nodes(get_docker_client(app), cluster.disconnected_nodes)
    return dataclasses.replace(cluster, disconnected_nodes=[])