This is an automated email from the ASF dual-hosted git repository.
RyanSkraba pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/avro.git
The following commit(s) were added to refs/heads/main by this push:
new 2cd8431ca3 Fixed byte compare (#3710)
2cd8431ca3 is described below
commit 2cd8431ca3ae95849a05b4105f8bcc9fe5d4b4e1
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 20554d4b1d..3562c33c6b 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]
