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