diff --git a/distributed/comm/tcp.py b/distributed/comm/tcp.py index c741aba83e..b395ff5237 100644 --- a/distributed/comm/tcp.py +++ b/distributed/comm/tcp.py @@ -665,7 +665,9 @@ async def _handle_stream(self, stream, address): try: await self.on_connection(comm) except CommClosedError: - logger.info("Connection from %s closed before handshake completed", address) + logger.debug( + "Connection from %s closed before handshake completed", address + ) return await self.comm_handler(comm)