Method write

internagent/stage.py:40–47

(self, data)

        self.streams = streams

    def write(self, data):
        for stream in self.streams:
            try:
                stream.write(data)
                stream.flush()  # Ensure immediate output
            except (ValueError, OSError):
                # Skip closed or invalid streams
                pass

    def flush(self):
        for stream in self.streams: