From 25289aef7c25f3280ea8d6f86f13c9c5a6941721 Mon Sep 17 00:00:00 2001 From: Jeremy Schoemaker Date: Wed, 5 Aug 2026 02:42:55 -0500 Subject: [PATCH] fix(retry): let streaming requests reach the retry loop _handle_stream_request converted every exception into a normal ("failed", ...) return value, so send_request's except clause never fired for a streaming request and the loop exited after one attempt. Re-raise instead; the final-failure return shape is unchanged. --- verify.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/verify.py b/verify.py index 50813bf..cfd48c3 100644 --- a/verify.py +++ b/verify.py @@ -354,7 +354,9 @@ async def _handle_stream_request(self, request: dict) -> tuple[str, dict]: return "success", response except Exception as e: logger.error(f"Stream request failed: {e}") - return "failed", {"error": str(e)} + # Re-raise so send_request's retry loop can see the failure. Returning + # here would exit the loop after a single attempt. + raise async def process_request(self, prepared_req: dict, data_index: int) -> dict: """Process a single request and run all validators."""