91f630f70959098facef4ab4e1a98d1f48f9a586,streaming/python/runtime/worker.py,JobWorker,on_reader_message_sync,#JobWorker#Any#,72

Before Change

    def on_reader_message_sync(self, buffer: bytes):
        used in direct call mode
        if self.reader_client is None:
            return b" " * 4  // special flag to indicate this actor not ready
        result = self.reader_client.on_reader_message_sync(buffer)
        return result.to_pybytes()

After Change

        downstream queue reader.
        
        if self.reader_client is None:
            return _NOT_READY_FLAG_
        result = self.reader_client.on_reader_message_sync(buffer)
        return result.to_pybytes()

    def on_writer_message(self, buffer: bytes):

Instances