This is an automated email from the ASF dual-hosted git repository.
RyanSkraba pushed a commit to branch branch-1.12
in repository https://gitbox.apache.org/repos/asf/avro.git
The following commit(s) were added to refs/heads/branch-1.12 by this push:
new c8456c82b0 Fixed byte compare (#3710)
c8456c82b0 is described below
commit c8456c82b05360bf1ebbed699f8ac9728b951774
Author: Valentin Valls <[email protected]>
AuthorDate: Sat May 2 10:08:00 2026 +0200
Fixed byte compare (#3710)
---
lang/py/avro/ipc.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/lang/py/avro/ipc.py b/lang/py/avro/ipc.py
index 7a5a5831f0..333f3b50a8 100644
--- a/lang/py/avro/ipc.py
+++ b/lang/py/avro/ipc.py
@@ -405,14 +405,14 @@ class FramedReader:
return b"".join(message)
while buffer.tell() < buffer_length:
chunk = self.reader.read(buffer_length - buffer.tell())
- if chunk == "":
+ if chunk == b"":
raise avro.errors.ConnectionClosedException("Reader read 0
bytes.")
buffer.write(chunk)
message.append(buffer.getvalue())
def _read_buffer_length(self):
read = self.reader.read(BUFFER_HEADER_LENGTH)
- if read == "":
+ if read == b"":
raise avro.errors.ConnectionClosedException("Reader read 0 bytes.")
return BIG_ENDIAN_INT_STRUCT.unpack(read)[0]
