From d2fa7b247e16580aa19c570326ec97b2d60c11a5 Mon Sep 17 00:00:00 2001 From: Mark Kockerbeck Date: Fri, 26 Jul 2024 12:06:17 -0700 Subject: [PATCH] Showing the message only if successfully decoded, #75 --- exo/networking/grpc/grpc_discovery.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/exo/networking/grpc/grpc_discovery.py b/exo/networking/grpc/grpc_discovery.py index a279c7f4..b607f083 100644 --- a/exo/networking/grpc/grpc_discovery.py +++ b/exo/networking/grpc/grpc_discovery.py @@ -102,8 +102,6 @@ class GRPCDiscovery(Discovery): print(traceback.format_exc()) async def on_listen_message(self, data, addr): - if DEBUG_DISCOVERY >= 2: print(f"received from peer {addr}: {data}") - if not data: return @@ -116,6 +114,7 @@ class GRPCDiscovery(Discovery): decoder = json.JSONDecoder(strict=False) message = decoder.decode(decoded_data) + if DEBUG_DISCOVERY >= 2: print(f"received from peer {addr}: {message}") if message['type'] == 'discovery' and message['node_id'] != self.node_id: peer_id = message['node_id']