'Load info from server for first query.
Queries the server if this is the first time a given query for
rtype has been issued.'

def _flood_cache_for_query(self, rtype, **filter_kwargs):

    query_ids = self._get_query_ids(rtype, filter_kwargs)
    if query_ids.issubset(self._satisfied_server_queries):
        return
    context = n_ctx.get_admin_context()
    resources = self._puller.bulk_pull(context, rtype, filter_kwargs=filter_kwargs)
    for resource in resources:
        if self._is_stale(rtype, resource):
            LOG.debug('Ignoring    stale    update    for    %s:    %s', rtype, resource)
            continue
        self._type_cache(rtype)[resource.id] = resource
    LOG.debug('%s    resources    returned    for    queries    %s', len(resources), query_ids)
    self._satisfied_server_queries.update(query_ids)
