diff --git a/verifiers/v1/serve/pool.py b/verifiers/v1/serve/pool.py index faa8b5f503..39a81a3418 100644 --- a/verifiers/v1/serve/pool.py +++ b/verifiers/v1/serve/pool.py @@ -195,9 +195,10 @@ async def run(self) -> None: payload, ) = await self.frontend.recv_multipart() if method == b"health": - await self.frontend.send_multipart( - [client_id, request_id, _HEALTH] - ) + with contextlib.suppress(zmq.ZMQError): + await self.frontend.send_multipart( + [client_id, request_id, _HEALTH] + ) else: # Pool capacity is measured in rollouts; one group request carries n. rollout_slots = 1