From a2730a6bd3acacd1632f4dc9fbb2874e9cd3cab2 Mon Sep 17 00:00:00 2001 From: Valentin Gauthier Date: Wed, 8 Nov 2023 03:47:54 +0100 Subject: [PATCH] bugfix --- etpproto/messages.py | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/etpproto/messages.py b/etpproto/messages.py index 99bb7eb..6b0c980 100644 --- a/etpproto/messages.py +++ b/etpproto/messages.py @@ -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( @@ -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))) @@ -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),