From 2c62d3bf32c92d85275bacacda2801ec04a61f48 Mon Sep 17 00:00:00 2001 From: Vaibhav159 Date: Mon, 10 Feb 2025 23:04:05 +0530 Subject: [PATCH] break once ConnectionClosed error --- src/pipecat/services/elevenlabs.py | 1 + src/pipecat/services/websocket_service.py | 1 + 2 files changed, 2 insertions(+) diff --git a/src/pipecat/services/elevenlabs.py b/src/pipecat/services/elevenlabs.py index b2805b55a..e0b985411 100644 --- a/src/pipecat/services/elevenlabs.py +++ b/src/pipecat/services/elevenlabs.py @@ -392,6 +392,7 @@ class ElevenLabsTTSService(WordTTSService, WebsocketService): await self._send_text("") except websockets.ConnectionClosed as e: logger.warning(f"{self} keepalive error: {e}") + break async def _send_text(self, text: str): if self._websocket: diff --git a/src/pipecat/services/websocket_service.py b/src/pipecat/services/websocket_service.py index 48ddeadaa..9c942b019 100644 --- a/src/pipecat/services/websocket_service.py +++ b/src/pipecat/services/websocket_service.py @@ -87,6 +87,7 @@ class WebsocketService(ABC): retry_count = 0 # Reset counter on successful message receive except websockets.ConnectionClosed as e: logger.warning(f"{self} connection closed: {e}") + break except Exception as e: retry_count += 1 if retry_count >= MAX_RETRIES: