From cc861d6b70a350b196330a7e031609ad5a8c2054 Mon Sep 17 00:00:00 2001 From: Gokul Js Date: Wed, 19 Nov 2025 22:46:36 +0530 Subject: [PATCH] Refactor WebSocket connection code in RimeNonJsonTTSService for improved readability --- src/pipecat/services/rime/tts.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/pipecat/services/rime/tts.py b/src/pipecat/services/rime/tts.py index 56d255e99..5c17ae664 100644 --- a/src/pipecat/services/rime/tts.py +++ b/src/pipecat/services/rime/tts.py @@ -746,7 +746,9 @@ class RimeNonJsonTTSService(InterruptibleTTSService): params = "&".join(f"{k}={v}" for k, v in self._settings.items() if v is not None) url = f"{self._url}?{params}" headers = {"Authorization": f"Bearer {self._api_key}"} - self._websocket = await websocket_connect(url, additional_headers=headers, max_size=1024 * 1024 * 16) + self._websocket = await websocket_connect( + url, additional_headers=headers, max_size=1024 * 1024 * 16 + ) await self._call_event_handler("on_connected") except Exception as e: logger.error(f"{self} exception: {e}")