'Find the queues owned by ``proc``.'

def _find_worker_queues(self, proc):

    try:
        return next((q for (q, owner) in items(self._queues) if (owner == proc)))
    except StopIteration:
        raise ValueError(proc)
