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

Removing the UserEndOfTurnFrame

Browse Source
This commit is contained in:
Filipi Fuchter
2025-04-17 17:53:31 -03:00
parent 6e06bf97c0
commit a390ce13a4
2 changed files with 0 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/pipecat/frames/frames.py
View File

@@ -571,15 +571,6 @@ class EmulateUserStoppedSpeakingFrame(SystemFrame):
pass pass
@dataclass
class UserEndOfTurnFrame(SystemFrame):
"""Emitted based on the Smart Turn model to indicate that the user has
completed their turn/sentence.
"""
pass
@dataclass @dataclass
class BotInterruptionFrame(SystemFrame): class BotInterruptionFrame(SystemFrame):
"""Emitted by when the bot should be interrupted. This will mainly cause the """Emitted by when the bot should be interrupted. This will mainly cause the

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

@@ -25,7 +25,6 @@ from pipecat.frames.frames import (
StartInterruptionFrame, StartInterruptionFrame,
StopInterruptionFrame, StopInterruptionFrame,
SystemFrame, SystemFrame,
UserEndOfTurnFrame,
UserStartedSpeakingFrame, UserStartedSpeakingFrame,
UserStoppedSpeakingFrame, UserStoppedSpeakingFrame,
VADParamsUpdateFrame, VADParamsUpdateFrame,
@@ -224,7 +223,6 @@ class BaseInputTransport(FrameProcessor):
async def _handle_end_of_turn_complete(self, state: EndOfTurnState): async def _handle_end_of_turn_complete(self, state: EndOfTurnState):
if state == EndOfTurnState.COMPLETE: if state == EndOfTurnState.COMPLETE:
await self.push_frame(UserEndOfTurnFrame())
await self._handle_user_interruption(UserStoppedSpeakingFrame()) await self._handle_user_interruption(UserStoppedSpeakingFrame())
async def _run_turn_analyzer( async def _run_turn_analyzer(