def __init__(self, name, pipe_instance): multiprocessing.Process.__init__(self, name=name) self.pipe = pipe_instance self._output_complete_event = multiprocessing.Event()