Skip to content

Commit

Permalink
bugfix
Browse files Browse the repository at this point in the history
  • Loading branch information
valentin-gauthier-geosiris committed Nov 8, 2023
1 parent 5d45629 commit a2730a6
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions etpproto/messages.py
Original file line number Diff line number Diff line change
Expand Up @@ -391,11 +391,9 @@ def decode_binary_message(
return_record_name_override=True,
)

logging.debug("HEADER", recMH, flush=True)
logging.debug("HEADER", recMH)

logging.debug(
"classmethod decode_binary_message", object_res, flush=True
)
logging.debug("classmethod decode_binary_message", object_res)
logging.debug(" ==> object_class ", object_class)

return Message(
Expand Down Expand Up @@ -442,8 +440,8 @@ def get_object_message(
message_flags: int = 0,
) -> Optional[Message]:
if etp_object:
logging.debug("get_object_message", etp_object, flush=True)
logging.debug("get_object_message", type(etp_object), flush=True)
logging.debug("get_object_message", etp_object)
logging.debug("get_object_message", type(etp_object))

objSchema = json.loads(avro_schema(type(etp_object)))

Expand Down Expand Up @@ -484,7 +482,7 @@ def decode_binary_message(
return_record_name_override=True,
)

logging.debug("decode_binary_message", object_res, flush=True)
logging.debug("decode_binary_message", object_res)

return (
mh.MessageHeader.parse_obj(recMH),
Expand Down

0 comments on commit a2730a6

Please sign in to comment.