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

BaseInputTransport: show VAD results when interruptions not allowed

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-02-06 07:40:03 -08:00
parent 4c77c3ed34
commit ee9cce64b2
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -130,17 +130,18 @@ class BaseInputTransport(FrameProcessor):
# #
async def _handle_interruptions(self, frame: Frame): async def _handle_interruptions(self, frame: Frame):
if self.interruptions_allowed: if isinstance(frame, UserStartedSpeakingFrame):
logger.debug("User started speaking")
# 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 self.interruptions_allowed:
logger.debug("User started speaking")
await self._start_interruption() await self._start_interruption()
# Push an out-of-band frame (i.e. not using the ordered push # Push an out-of-band frame (i.e. not using the ordered push
# frame task) to stop everything, specially at the output # frame task) to stop everything, specially at the output
# transport. # transport.
await self.push_frame(StartInterruptionFrame()) await self.push_frame(StartInterruptionFrame())
elif isinstance(frame, UserStoppedSpeakingFrame): elif isinstance(frame, UserStoppedSpeakingFrame):
logger.debug("User stopped speaking") logger.debug("User stopped speaking")
if self.interruptions_allowed:
await self._stop_interruption() await self._stop_interruption()
await self.push_frame(StopInterruptionFrame()) await self.push_frame(StopInterruptionFrame())