pub fn handle_cluster_error<T>(
    msg: &str,
    cluster: &Cluster,
    res: Result<T>
) -> Result<T>