From d0f8c2d95ec8d45acd9b196eed8e21e7895feea9 Mon Sep 17 00:00:00 2001 From: 0xnightwind Date: Fri, 27 Jun 2025 22:45:38 +0200 Subject: [PATCH] hivemind/dht/dht.py: handle BlockingIOError and EOFError while waiting for msg on _inner_pipe.rev() for `method, args, kwargs = self._inner_pipe.recv()` exceptions being caught don't handle `BlockingIOError` and `EOFError`. This is important to be included in the list of exceptions being handled because sometimes the resources aren't available. Signed-off-by: 0xnightwind --- hivemind/dht/dht.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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