From 33274980675b56cdca7ccc3cc5430ae0a70dc6cb Mon Sep 17 00:00:00 2001 From: Mohammed Zaid Hussain Date: Wed, 1 Jul 2026 23:30:10 +0530 Subject: [PATCH] fix: remove unreachable error check inside thread event block --- src/openai/_streaming.py | 31 ------------------------------- 1 file changed, 31 deletions(-) diff --git a/src/openai/_streaming.py b/src/openai/_streaming.py index 45c13cc11d..8fe85ba5cc 100644 --- a/src/openai/_streaming.py +++ b/src/openai/_streaming.py @@ -63,24 +63,8 @@ def __stream__(self) -> Iterator[_T]: if sse.data.startswith("[DONE]"): break - # we have to special case the Assistants `thread.` events since we won't have an "event" key in the data if sse.event and sse.event.startswith("thread."): data = sse.json() - - if sse.event == "error" and is_mapping(data) and data.get("error"): - message = None - error = data.get("error") - if is_mapping(error): - message = error.get("message") - if not message or not isinstance(message, str): - message = "An error occurred during streaming" - - raise APIError( - message=message, - request=self.response.request, - body=data["error"], - ) - yield process_data(data={"data": data, "event": sse.event}, cast_to=cast_to, response=response) else: data = sse.json() @@ -176,21 +160,6 @@ async def __stream__(self) -> AsyncIterator[_T]: # we have to special case the Assistants `thread.` events since we won't have an "event" key in the data if sse.event and sse.event.startswith("thread."): data = sse.json() - - if sse.event == "error" and is_mapping(data) and data.get("error"): - message = None - error = data.get("error") - if is_mapping(error): - message = error.get("message") - if not message or not isinstance(message, str): - message = "An error occurred during streaming" - - raise APIError( - message=message, - request=self.response.request, - body=data["error"], - ) - yield process_data(data={"data": data, "event": sse.event}, cast_to=cast_to, response=response) else: data = sse.json()