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

Added changelog for split_sentences and code tidy for end of turn handling.

Browse Source
This commit is contained in:
Sam Sykes
2026-01-07 07:41:49 -08:00
parent d5d2156689
commit 3ec89e49bf
2 changed files with 5 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
changelog/3328.added.md Normal file
View File

@@ -0,0 +1 @@
- Added `split_sentences` parameter to `SpeechmaticsSTTService` to control sentence splitting behavior for finals on sentence boundaries.

15
src/pipecat/services/speechmatics/stt.py
View File

@@ -27,6 +27,7 @@ from pipecat.frames.frames import (
InterimTranscriptionFrame, InterimTranscriptionFrame,
StartFrame, StartFrame,
TranscriptionFrame, TranscriptionFrame,
UserStoppedSpeakingFrame,
VADUserStartedSpeakingFrame, VADUserStartedSpeakingFrame,
VADUserStoppedSpeakingFrame, VADUserStoppedSpeakingFrame,
) )
@@ -621,12 +622,8 @@ class SpeechmaticsSTTService(STTService):
""" """
logger.debug(f"{self} StartOfTurn received") logger.debug(f"{self} StartOfTurn received")
# await self.start_processing_metrics() # await self.start_processing_metrics()
await self.push_interruption_task_frame_and_wait()
# Emit VAD events if enabled await self.broadcast_frame(VADUserStartedSpeakingFrame)
if self._enable_vad:
await self.push_interruption_task_frame_and_wait()
logger.debug(f"{self} sending VADUserStartedSpeakingFrame")
await self.broadcast_frame(VADUserStartedSpeakingFrame)
async def _handle_end_of_turn(self, message: dict[str, Any]) -> None: async def _handle_end_of_turn(self, message: dict[str, Any]) -> None:
"""Handle EndOfTurn events. """Handle EndOfTurn events.
@@ -645,11 +642,7 @@ class SpeechmaticsSTTService(STTService):
""" """
logger.debug(f"{self} EndOfTurn received") logger.debug(f"{self} EndOfTurn received")
# await self.stop_processing_metrics() # await self.stop_processing_metrics()
await self.broadcast_frame(UserStoppedSpeakingFrame)
# Emit VAD events if enabled
if self._enable_vad:
logger.debug(f"{self} sending VADUserStoppedSpeakingFrame")
await self.broadcast_frame(VADUserStoppedSpeakingFrame)
async def _handle_speakers_result(self, message: dict[str, Any]) -> None: async def _handle_speakers_result(self, message: dict[str, Any]) -> None:
"""Handle SpeakersResult events. """Handle SpeakersResult events.