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

transports(base): log when user is speaking

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-05-22 17:57:25 -07:00
parent e9965347b5
commit fcec0eb812
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/base_input.py
View File

@@ -137,10 +137,12 @@ class BaseInputTransport(FrameProcessor):
if self._allow_interruptions: if self._allow_interruptions:
# Make sure we notify about interruptions quickly out-of-band # Make sure we notify about interruptions quickly out-of-band
if isinstance(frame, UserStartedSpeakingFrame): if isinstance(frame, UserStartedSpeakingFrame):
logger.debug("User started speaking")
self._push_frame_task.cancel() self._push_frame_task.cancel()
self._create_push_task() self._create_push_task()
await self.push_frame(StartInterruptionFrame()) await self.push_frame(StartInterruptionFrame())
elif isinstance(frame, UserStoppedSpeakingFrame): elif isinstance(frame, UserStoppedSpeakingFrame):
logger.debug("User stopped speaking")
await self.push_frame(StopInterruptionFrame()) await self.push_frame(StopInterruptionFrame())
await self._internal_push_frame(frame) await self._internal_push_frame(frame)