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

Merge pull request #3206 from pipecat-ai/vp-update-bot-latency-observer

Browse Source 
use VADUserStarted/StoppedSpeakingFrame s in user_bot_latency_log_observer.py
This commit is contained in:
Vanessa Pyne
2025-12-08 11:37:56 -06:00
committed by GitHub
parent 4517475db7 540a48b1b6
commit b09d8bd595
2 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
changelog/3206.changed.md Normal file
View File

@@ -0,0 +1,3 @@
- `UserBotLatencyLogObserver` now uses `VADUserStartedSpeakingFrame` and
`VADUserStoppedSpeakingFrame` to determine latency from user stopped speaking
to bot started speaking.

8
src/pipecat/observers/loggers/user_bot_latency_log_observer.py
View File

@@ -15,8 +15,8 @@ from pipecat.frames.frames import (
BotStartedSpeakingFrame, BotStartedSpeakingFrame,
CancelFrame, CancelFrame,
EndFrame, EndFrame,
UserStartedSpeakingFrame, VADUserStartedSpeakingFrame,
UserStoppedSpeakingFrame, VADUserStoppedSpeakingFrame,
) )
from pipecat.observers.base_observer import BaseObserver, FramePushed from pipecat.observers.base_observer import BaseObserver, FramePushed
from pipecat.processors.frame_processor import FrameDirection from pipecat.processors.frame_processor import FrameDirection
@@ -56,9 +56,9 @@ class UserBotLatencyLogObserver(BaseObserver):
self._processed_frames.add(data.frame.id) self._processed_frames.add(data.frame.id)
if isinstance(data.frame, UserStartedSpeakingFrame): if isinstance(data.frame, VADUserStartedSpeakingFrame):
self._user_stopped_time = 0 self._user_stopped_time = 0
elif isinstance(data.frame, UserStoppedSpeakingFrame): elif isinstance(data.frame, VADUserStoppedSpeakingFrame):
self._user_stopped_time = time.time() self._user_stopped_time = time.time()
elif isinstance(data.frame, (EndFrame, CancelFrame)): elif isinstance(data.frame, (EndFrame, CancelFrame)):
self._log_summary() self._log_summary()