diff --git a/pyproject.toml b/pyproject.toml index aec1fce8cd..e3ca72faf2 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -38,7 +38,7 @@ Homepage = "https://github.com/openai/openai-python" Repository = "https://github.com/openai/openai-python" [project.optional-dependencies] -realtime = ["websockets >= 13, < 15"] +realtime = ["websockets >= 13, < 16"] [tool.rye] managed = true diff --git a/requirements-dev.lock b/requirements-dev.lock index be626d274b..500eb9eca2 100644 --- a/requirements-dev.lock +++ b/requirements-dev.lock @@ -100,7 +100,7 @@ typing-extensions==4.12.2 # via pyright virtualenv==20.24.5 # via nox -websockets==14.2 +websockets==15.0.1 # via openai zipp==3.17.0 # via importlib-metadata diff --git a/requirements.lock b/requirements.lock index c704fd8abd..75e37dea53 100644 --- a/requirements.lock +++ b/requirements.lock @@ -43,5 +43,5 @@ typing-extensions==4.12.2 # via openai # via pydantic # via pydantic-core -websockets==14.2 +websockets==15.0.1 # via openai diff --git a/src/openai/resources/beta/realtime/realtime.py b/src/openai/resources/beta/realtime/realtime.py index 5c2ae8997c..f8cba6da17 100644 --- a/src/openai/resources/beta/realtime/realtime.py +++ b/src/openai/resources/beta/realtime/realtime.py @@ -275,10 +275,6 @@ async def recv_bytes(self) -> bytes: """ message = await self._connection.recv(decode=False) log.debug(f"Received websocket message: %s", message) - if not isinstance(message, bytes): - # passing `decode=False` should always result in us getting `bytes` back - raise TypeError(f"Expected `.recv(decode=False)` to return `bytes` but got {type(message)}") - return message async def send(self, event: RealtimeClientEvent | RealtimeClientEventParam) -> None: @@ -454,10 +450,6 @@ def recv_bytes(self) -> bytes: """ message = self._connection.recv(decode=False) log.debug(f"Received websocket message: %s", message) - if not isinstance(message, bytes): - # passing `decode=False` should always result in us getting `bytes` back - raise TypeError(f"Expected `.recv(decode=False)` to return `bytes` but got {type(message)}") - return message def send(self, event: RealtimeClientEvent | RealtimeClientEventParam) -> None: