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

Allows defining whether Speechmatics should send an interruption when the user’s turn has started.

Browse Source
This commit is contained in:
filipi87
2026-01-08 10:50:33 -03:00
parent 68c9c01747
commit 3069deb92f
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -287,6 +287,7 @@ class SpeechmaticsSTTService(STTService):
base_url: str | None = None, base_url: str | None = None,
sample_rate: int | None = None, sample_rate: int | None = None,
params: InputParams | None = None, params: InputParams | None = None,
should_interrupt: bool = True,
**kwargs, **kwargs,
): ):
"""Initialize the Speechmatics STT service. """Initialize the Speechmatics STT service.
@@ -298,6 +299,7 @@ class SpeechmaticsSTTService(STTService):
or defaults to `wss://eu2.rt.speechmatics.com/v2`. or defaults to `wss://eu2.rt.speechmatics.com/v2`.
sample_rate: Optional audio sample rate in Hz. sample_rate: Optional audio sample rate in Hz.
params: Optional[InputParams]: Input parameters for the service. params: Optional[InputParams]: Input parameters for the service.
should_interrupt: Determine whether the bot should be interrupted when Speechmatics detects that the user is speaking.
**kwargs: Additional arguments passed to STTService. **kwargs: Additional arguments passed to STTService.
""" """
super().__init__(sample_rate=sample_rate, **kwargs) super().__init__(sample_rate=sample_rate, **kwargs)
@@ -316,6 +318,7 @@ class SpeechmaticsSTTService(STTService):
# Default params # Default params
params = params or SpeechmaticsSTTService.InputParams() params = params or SpeechmaticsSTTService.InputParams()
self._should_interrupt = should_interrupt
# Deprecation check # Deprecation check
self._check_deprecated_args(kwargs, params) self._check_deprecated_args(kwargs, params)
@@ -623,7 +626,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.broadcast_frame(UserStartedSpeakingFrame) await self.broadcast_frame(UserStartedSpeakingFrame)
await self.push_interruption_task_frame_and_wait() if self._should_interrupt:
await self.push_interruption_task_frame_and_wait()
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.