'Get the cluster nodes that own the specified aggregates.'

def _get_nodes_for_aggregates(self, aggr_names):

    node_names = set()
    aggr_node_map = {}
    for aggr_name in aggr_names:
        node_name = self.zapi_client.get_node_for_aggregate(aggr_name)
        if node_name:
            node_names.add(node_name)
            aggr_node_map[aggr_name] = node_name
    return (node_names, aggr_node_map)
