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

Fix metrics calculations

Browse Source
This commit is contained in:
Mark Backman
2024-12-21 13:25:43 -05:00
parent bce218915e
commit 6fabb7e7d5
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/pipecat/services/fish.py
View File

@@ -156,7 +156,6 @@ class FishAudioTTSService(TTSService):
if isinstance(msg, dict): if isinstance(msg, dict):
event = msg.get("event") event = msg.get("event")
if event == "audio": if event == "audio":
await self.stop_ttfb_metrics()
audio_data = msg.get("audio") audio_data = msg.get("audio")
# Only process larger chunks to remove msgpack overhead # Only process larger chunks to remove msgpack overhead
if audio_data and len(audio_data) > 1024: if audio_data and len(audio_data) > 1024:
@@ -164,6 +163,7 @@ class FishAudioTTSService(TTSService):
audio_data, self._settings["sample_rate"], 1 audio_data, self._settings["sample_rate"], 1
) )
await self.push_frame(frame) await self.push_frame(frame)
await self.stop_ttfb_metrics()
continue continue
except Exception as e: except Exception as e:
@@ -216,6 +216,7 @@ class FishAudioTTSService(TTSService):
if not self._request_id: if not self._request_id:
await self.start_ttfb_metrics() await self.start_ttfb_metrics()
await self.start_tts_usage_metrics(text)
yield TTSStartedFrame() yield TTSStartedFrame()
self._request_id = str(uuid.uuid4()) self._request_id = str(uuid.uuid4())