def get_output(self): ctx = multiprocessing.get_context('spawn') # out_queue = ctx.Queue() out_queue = utils.Queue(ctx=ctx) # .get_context() self.out_queues.append(out_queue) return out_queue