'Called to clean up queues after process exit.'

def _process_cleanup_queues(self, proc):

    if (not proc.dead):
        try:
            self._queues[self._find_worker_queues(proc)] = None
        except (KeyError, ValueError):
            pass
