diff --git a/src/pipecat/transports/base_input.py b/src/pipecat/transports/base_input.py index b76ae61ef..f923942e6 100644 --- a/src/pipecat/transports/base_input.py +++ b/src/pipecat/transports/base_input.py @@ -48,7 +48,7 @@ from pipecat.metrics.metrics import MetricsData from pipecat.processors.frame_processor import FrameDirection, FrameProcessor from pipecat.transports.base_transport import TransportParams -AUDIO_INPUT_TIMEOUT_SECS = 1.0 +AUDIO_INPUT_TIMEOUT_SECS = 0.5 class BaseInputTransport(FrameProcessor): @@ -449,8 +449,6 @@ class BaseInputTransport(FrameProcessor): if not audio_received: continue - logger.debug(f"{self}: audio not received for more than {AUDIO_INPUT_TIMEOUT_SECS}") - ################################################################### # DEPRECATED. if self._user_speaking: diff --git a/src/pipecat/turns/user_turn_strategies.py b/src/pipecat/turns/user_turn_strategies.py index eab64377a..0435f141c 100644 --- a/src/pipecat/turns/user_turn_strategies.py +++ b/src/pipecat/turns/user_turn_strategies.py @@ -9,6 +9,7 @@ from dataclasses import dataclass from typing import List, Optional +from pipecat.audio.turn.smart_turn.local_smart_turn_v3 import LocalSmartTurnAnalyzerV3 from pipecat.turns.user_start import ( BaseUserTurnStartStrategy, ExternalUserTurnStartStrategy, @@ -18,7 +19,7 @@ from pipecat.turns.user_start import ( from pipecat.turns.user_stop import ( BaseUserTurnStopStrategy, ExternalUserTurnStopStrategy, - TranscriptionUserTurnStopStrategy, + TurnAnalyzerUserTurnStopStrategy, ) @@ -29,7 +30,7 @@ class UserTurnStrategies: If no strategies are specified, the following defaults are used: start: [VADUserTurnStartStrategy, TranscriptionUserTurnStartStrategy] - stop: [TranscriptionUserTurnStopStrategy] + stop: [TurnAnalyzerUserTurnStopStrategy(LocalSmartTurnAnalyzerV3)] Attributes: start: A list of user turn start strategies used to detect when @@ -46,7 +47,7 @@ class UserTurnStrategies: if not self.start: self.start = [VADUserTurnStartStrategy(), TranscriptionUserTurnStartStrategy()] if not self.stop: - self.stop = [TranscriptionUserTurnStopStrategy()] + self.stop = [TurnAnalyzerUserTurnStopStrategy(turn_analyzer=LocalSmartTurnAnalyzerV3())] @dataclass