From 464637214fa31fa3cb1de3e6898d5579d2a9ef9f Mon Sep 17 00:00:00 2001 From: Sisyphus Date: Tue, 30 Jun 2026 02:35:45 +0800 Subject: [PATCH] fix: remove dead error event code in _streaming.py The error event handling inside the Assistants thread. event branch is unreachable because 'error' doesn't start with 'thread.'. The helper already handles this case correctly in the else branch. --- src/openai/_streaming.py | 28 ---------------------------- 1 file changed, 28 deletions(-) diff --git a/src/openai/_streaming.py b/src/openai/_streaming.py index 45c13cc11d..e1de1c71df 100644 --- a/src/openai/_streaming.py +++ b/src/openai/_streaming.py @@ -67,20 +67,6 @@ def __stream__(self) -> Iterator[_T]: 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() @@ -177,20 +163,6 @@ async def __stream__(self) -> AsyncIterator[_T]: 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()