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

Preventing the duplicated BotStartedSpeakingFrame and BotStoppedSpeakingFrame.

Browse Source
This commit is contained in:
filipi87
2026-02-19 15:49:22 -03:00
parent b1cee140b9
commit d608c400f9
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -613,6 +613,11 @@ class BaseOutputTransport(FrameProcessor):
downstream_frame.transport_destination = self._destination downstream_frame.transport_destination = self._destination
upstream_frame = BotStartedSpeakingFrame() upstream_frame = BotStartedSpeakingFrame()
upstream_frame.transport_destination = self._destination upstream_frame.transport_destination = self._destination
# Setting the siblings id
upstream_frame.broadcasted_sibling_id = downstream_frame.id
downstream_frame.broadcasted_sibling_id = upstream_frame.id
await self._transport.push_frame(downstream_frame) await self._transport.push_frame(downstream_frame)
await self._transport.push_frame(upstream_frame, FrameDirection.UPSTREAM) await self._transport.push_frame(upstream_frame, FrameDirection.UPSTREAM)
@@ -635,6 +640,11 @@ class BaseOutputTransport(FrameProcessor):
downstream_frame.transport_destination = self._destination downstream_frame.transport_destination = self._destination
upstream_frame = BotStoppedSpeakingFrame() upstream_frame = BotStoppedSpeakingFrame()
upstream_frame.transport_destination = self._destination upstream_frame.transport_destination = self._destination
# Setting the siblings id
upstream_frame.broadcasted_sibling_id = downstream_frame.id
downstream_frame.broadcasted_sibling_id = upstream_frame.id
await self._transport.push_frame(downstream_frame) await self._transport.push_frame(downstream_frame)
await self._transport.push_frame(upstream_frame, FrameDirection.UPSTREAM) await self._transport.push_frame(upstream_frame, FrameDirection.UPSTREAM)