def __init__(self, name, pipe_instance): threading.Thread.__init__(self, name=name) self.pipe = pipe_instance self._output_complete_event = threading.Event()