fix: Clean up debug logs

lablup · Feb 28, 2024 · 581f450 · 581f450
1 parent 488c479
commit 581f450
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/callosum/lower/zeromq.py b/src/callosum/lower/zeromq.py
@@ -242,7 +242,15 @@ async def recv_message(self) -> AsyncGenerator[Optional[RawHeaderBody], None]:
                     else:
                         # client
                         yield RawHeaderBody(raw_header, raw_body, None)
+                else:
+                    # Ignore if the peer has sent a malformed multipart message.
+                    log.debug(
+                        "ZeroMQRPCConnection.recv_message(): "
+                        "ignoring an invalid message from the peer..."
+                    )
             except Exception as e:
+                # ValueError may happen when there are garbage packets accepted by
+                # the zmq socket.
                 log.debug(
                     "ZeroMQRPCConnection.recv_message(): "
                     "exception caught in the recv loop, continuing...",