diff --git a/hivemind/dht/dht.py b/hivemind/dht/dht.py index f9eb86bc2..097d559b5 100644 --- a/hivemind/dht/dht.py +++ b/hivemind/dht/dht.py @@ -126,7 +126,7 @@ async def _run(): continue try: method, args, kwargs = self._inner_pipe.recv() - except (OSError, ConnectionError, RuntimeError) as e: + except (OSError, ConnectionError, RuntimeError, BlockingIOError, EOFError) as e: logger.exception(e) await asyncio.sleep(self._node.protocol.wait_timeout) continue