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

And remove the request-id.

Browse Source
This commit is contained in:
laurent
2025-12-05 10:35:19 +01:00
parent 8c6b2edb25
commit 283bbb385c
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/pipecat/services/gradium/tts.py
View File

@@ -96,7 +96,6 @@ class GradiumTTSService(InterruptibleWordTTSService):
# State tracking # State tracking
self._receive_task = None self._receive_task = None
self._request_id = None
def can_generate_metrics(self) -> bool: def can_generate_metrics(self) -> bool:
"""Check if this service can generate processing metrics. """Check if this service can generate processing metrics.
@@ -221,7 +220,6 @@ class GradiumTTSService(InterruptibleWordTTSService):
await self.push_error(error_msg=f"Unknown error occurred: {e}", exception=e) await self.push_error(error_msg=f"Unknown error occurred: {e}", exception=e)
finally: finally:
self._websocket = None self._websocket = None
self._request_id = None
await self._call_event_handler("on_disconnected") await self._call_event_handler("on_disconnected")
def _get_websocket(self): def _get_websocket(self):
@@ -301,10 +299,7 @@ class GradiumTTSService(InterruptibleWordTTSService):
await self._connect() await self._connect()
try: try:
if not self._request_id: yield TTSStartedFrame()
await self.start_ttfb_metrics()
yield TTSStartedFrame()
self._request_id = str(uuid.uuid4())
msg = self._build_msg(text=text) msg = self._build_msg(text=text)
await self._get_websocket().send(json.dumps(msg)) await self._get_websocket().send(json.dumps(msg))