From ac3fa7f91f42394f33036ea01ad8c0f08d2b9890 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 16 Jan 2026 14:46:25 -0800 Subject: [PATCH] BaseOuputTransport: minor cleanup --- src/pipecat/transports/base_output.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py index a19d65b75..c4f59a61d 100644 --- a/src/pipecat/transports/base_output.py +++ b/src/pipecat/transports/base_output.py @@ -403,7 +403,7 @@ class BaseOutputTransport(FrameProcessor): # Last time a BotSpeakingFrame was pushed. self._bot_speaking_frame_time = 0 # How often a BotSpeakingFrame should be pushed (value should be - # lower than the audio chunks). + # greater than the audio chunks to have any effect). self._bot_speaking_frame_period = 0.2 # Last time the bot actually spoke. self._bot_speech_last_time = 0 @@ -644,8 +644,7 @@ class BaseOutputTransport(FrameProcessor): diff_time = time.time() - self._bot_speaking_frame_time if diff_time >= self._bot_speaking_frame_period: - await self._transport.push_frame(BotSpeakingFrame()) - await self._transport.push_frame(BotSpeakingFrame(), FrameDirection.UPSTREAM) + await self._transport.broadcast_frame(BotSpeakingFrame) self._bot_speaking_frame_time = time.time() self._bot_speech_last_time = time.time()