Skip to content

Commit

Permalink
serialize write backup
Browse files Browse the repository at this point in the history
  • Loading branch information
pandalee99 committed Feb 5, 2025
1 parent 0e78968 commit d818c28
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions python/pyfury/_serializer.py
Original file line number Diff line number Diff line change
Expand Up @@ -302,7 +302,7 @@ def write(self, buffer, value: Dict):
if self.use_chunk_serialize:
self.chunk_write_elements(buffer, value)
else:
self.write_elements(buffer,value)
self.write_elements(buffer, value)

def write_elements(self, buffer, value: Dict):
buffer.write_varuint32(len(value))
Expand Down Expand Up @@ -333,7 +333,7 @@ def chunk_write_elements(self, buffer, value: Dict):
buffer.write_varuint32(len(value))

chunk_size = 0
max_chunk_size = 128
max_chunk_size = 128 # Define maximum chunk size

for k, v in value.items():
if chunk_size >= max_chunk_size:
Expand All @@ -343,7 +343,6 @@ def chunk_write_elements(self, buffer, value: Dict):
chunk_size += 1

def serialize_key_value(self, buffer, key, value):

key_cls = type(key)
if key_cls is str:
buffer.write_int16(NOT_NULL_STRING_FLAG)
Expand Down Expand Up @@ -385,7 +384,6 @@ def chunk_read_elements(self, buffer):
return map_

def read_chunk(self, buffer, map_, chunk_header, size):

chunk_size = buffer.read_unsigned_byte()

for i in range(chunk_size):
Expand All @@ -409,7 +407,6 @@ def read_value(self, buffer, chunk_header):
return self.read_ref(buffer)

def read_ref(self, buffer):

return self.fury.deserialize_ref(buffer)

def read_elements(self, buffer):
Expand Down

0 comments on commit d818c28

Please sign in to comment.