wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Make OpenAIRealtimeLLMService's websocket send method more resilient. Previously, it was possible for a websocket send attempt to occur during a disconnect.

Browse Source
This commit is contained in:
Paul Kompfner
2025-10-21 11:41:02 -04:00
parent 46e97c57c2
commit 3761804146
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/services/openai/realtime/llm.py
View File

@@ -456,10 +456,14 @@ class OpenAIRealtimeLLMService(LLMService):
async def _ws_send(self, realtime_message): async def _ws_send(self, realtime_message):
try: try:
if self._websocket: if not self._disconnecting and self._websocket:
await self._websocket.send(json.dumps(realtime_message)) await self._websocket.send(json.dumps(realtime_message))
except Exception as e: except Exception as e:
if self._disconnecting: if self._disconnecting or not self._websocket:
# We're in the process of disconnecting.
# (If not self._websocket, that could indicate that we
# somehow *started* the websocket send attempt while we still
# had a connection)
return return
logger.error(f"Error sending message to websocket: {e}") logger.error(f"Error sending message to websocket: {e}")
# In server-to-server contexts, a WebSocket error should be quite rare. Given how hard # In server-to-server contexts, a WebSocket error should be quite rare. Given how hard