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."""