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

BaseOuputTransport: minor cleanup

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2026-01-16 14:46:25 -08:00
parent 6eadad53b2
commit ac3fa7f91f
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/pipecat/transports/base_output.py
View File

@@ -403,7 +403,7 @@ class BaseOutputTransport(FrameProcessor):
# Last time a BotSpeakingFrame was pushed. # Last time a BotSpeakingFrame was pushed.
self._bot_speaking_frame_time = 0 self._bot_speaking_frame_time = 0
# How often a BotSpeakingFrame should be pushed (value should be # 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 self._bot_speaking_frame_period = 0.2
# Last time the bot actually spoke. # Last time the bot actually spoke.
self._bot_speech_last_time = 0 self._bot_speech_last_time = 0
@@ -644,8 +644,7 @@ class BaseOutputTransport(FrameProcessor):
diff_time = time.time() - self._bot_speaking_frame_time diff_time = time.time() - self._bot_speaking_frame_time
if diff_time >= self._bot_speaking_frame_period: if diff_time >= self._bot_speaking_frame_period:
await self._transport.push_frame(BotSpeakingFrame()) await self._transport.broadcast_frame(BotSpeakingFrame)
await self._transport.push_frame(BotSpeakingFrame(), FrameDirection.UPSTREAM)
self._bot_speaking_frame_time = time.time() self._bot_speaking_frame_time = time.time()
self._bot_speech_last_time = time.time() self._bot_speech_last_time = time.time()