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

Merge pull request #1944 from pipecat-ai/fixing_tavus_transport

Browse Source 
Adding the direction when pushing the frame.
This commit is contained in:
Filipi da Silva Fuchter
2025-06-02 15:21:58 -03:00
committed by GitHub
parent ab18b280e9 b828bfd890
commit 7f7cd96211
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -196,10 +196,10 @@ class BaseInputTransport(FrameProcessor):
await self._handle_bot_interruption(frame) await self._handle_bot_interruption(frame)
elif isinstance(frame, BotStartedSpeakingFrame): elif isinstance(frame, BotStartedSpeakingFrame):
await self._handle_bot_started_speaking(frame) await self._handle_bot_started_speaking(frame)
await self.push_frame(frame) await self.push_frame(frame, direction)
elif isinstance(frame, BotStoppedSpeakingFrame): elif isinstance(frame, BotStoppedSpeakingFrame):
await self._handle_bot_stopped_speaking(frame) await self._handle_bot_stopped_speaking(frame)
await self.push_frame(frame) await self.push_frame(frame, direction)
elif isinstance(frame, EmulateUserStartedSpeakingFrame): elif isinstance(frame, EmulateUserStartedSpeakingFrame):
logger.debug("Emulating user started speaking") logger.debug("Emulating user started speaking")
await self._handle_user_interruption(UserStartedSpeakingFrame(emulated=True)) await self._handle_user_interruption(UserStartedSpeakingFrame(emulated=True))