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

Increase WebSocket max size limit in RimeNonJsonTTSService to enhance data handling capacity

Browse Source
This commit is contained in:
Gokul Js
2025-11-19 22:44:50 +05:30
parent da671cd232
commit de4e9c54f6
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/services/rime/tts.py
View File

@@ -746,7 +746,7 @@ class RimeNonJsonTTSService(InterruptibleTTSService):
params = "&".join(f"{k}={v}" for k, v in self._settings.items() if v is not None) params = "&".join(f"{k}={v}" for k, v in self._settings.items() if v is not None)
url = f"{self._url}?{params}" url = f"{self._url}?{params}"
headers = {"Authorization": f"Bearer {self._api_key}"} headers = {"Authorization": f"Bearer {self._api_key}"}
self._websocket = await websocket_connect(url, additional_headers=headers) self._websocket = await websocket_connect(url, additional_headers=headers, max_size=1024 * 1024 * 16)
await self._call_event_handler("on_connected") await self._call_event_handler("on_connected")
except Exception as e: except Exception as e:
logger.error(f"{self} exception: {e}") logger.error(f"{self} exception: {e}")