From 04882f6f2ae1c2d93b2311fc4d4093c82ae6bf50 Mon Sep 17 00:00:00 2001 From: Paul Kompfner Date: Mon, 30 Mar 2026 22:32:08 -0400 Subject: [PATCH] Simplify _connect_websocket guard and remove unused State import --- src/pipecat/services/openai/responses/llm.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/pipecat/services/openai/responses/llm.py b/src/pipecat/services/openai/responses/llm.py index 0015278df..63d0c71ee 100644 --- a/src/pipecat/services/openai/responses/llm.py +++ b/src/pipecat/services/openai/responses/llm.py @@ -54,7 +54,6 @@ from pipecat.utils.tracing.service_decorators import traced_llm try: from websockets.asyncio.client import connect as websocket_connect from websockets.exceptions import ConnectionClosed - from websockets.protocol import State except ModuleNotFoundError as e: logger.error(f"Exception: {e}") logger.error("In order to use OpenAI, you need to `pip install pipecat-ai[openai]`.") @@ -404,7 +403,7 @@ class OpenAIResponsesLLMService(_BaseOpenAIResponsesLLMService, WebsocketLLMServ async def _connect_websocket(self): """Establish the WebSocket connection.""" try: - if self._websocket and self._websocket.state is not State.CLOSED: + if self._websocket: return self._websocket = await websocket_connect( uri=self._ws_url,