Skip to content

Commit

Permalink
fix: avoid parsing distributed configuration on push request
Browse files Browse the repository at this point in the history
  • Loading branch information
tglman committed Jun 6, 2024
1 parent 5e3926c commit 71b36eb
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions pyorient/messages/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -200,9 +200,9 @@ def _decode_header(self):
# 80: \x50 Request Push 1 byte: Push command id
push_command_id = self._decode_field(FIELD_BYTE)
push_message = self._decode_field( FIELD_STRING )
_, payload = self.get_serializer().decode(push_message)
if self._push_callback:
self._push_callback(push_command_id, payload)
# _, payload = self.get_serializer().decode(push_message)
# if self._push_callback:
# self._push_callback(push_command_id, payload)

# self._cluster_map.set_hi_availability_list(
# self._decode_field( FIELD_STRING )
Expand All @@ -214,9 +214,10 @@ def _decode_header(self):
while end_flag == 3:
self._decode_field( FIELD_INT ) # FAKE SESSION ID = 2^-31
self._decode_field( FIELD_BYTE ) # 80: 0x50 Request Push
self._cluster_map.set_hi_availability_list(
self._decode_field( FIELD_STRING )
) # JSON WITH THE NEW CLUSTER CFG
cluster_map_field = self._decode_field( FIELD_STRING );
#self._cluster_map.set_hi_availability_list(
# cluster_map_field
#) # JSON WITH THE NEW CLUSTER CFG

"""
:type: self._cluster_map pyorient.messages.cluster.Information
Expand Down

0 comments on commit 71b36eb

Please sign in to comment.