From fcec0eb812cc088afdd88093791208b66b55140b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Wed, 22 May 2024 17:57:25 -0700 Subject: [PATCH] transports(base): log when user is speaking --- src/pipecat/transports/base_input.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/pipecat/transports/base_input.py b/src/pipecat/transports/base_input.py index 4d4e4c987..71733c59c 100644 --- a/src/pipecat/transports/base_input.py +++ b/src/pipecat/transports/base_input.py @@ -137,10 +137,12 @@ class BaseInputTransport(FrameProcessor): if self._allow_interruptions: # Make sure we notify about interruptions quickly out-of-band if isinstance(frame, UserStartedSpeakingFrame): + logger.debug("User started speaking") self._push_frame_task.cancel() self._create_push_task() await self.push_frame(StartInterruptionFrame()) elif isinstance(frame, UserStoppedSpeakingFrame): + logger.debug("User stopped speaking") await self.push_frame(StopInterruptionFrame()) await self._internal_push_frame(frame)