diff --git a/api/services/pipecat/audio_config.py b/api/services/pipecat/audio_config.py index a0834947..1c25a67b 100644 --- a/api/services/pipecat/audio_config.py +++ b/api/services/pipecat/audio_config.py @@ -52,16 +52,6 @@ class AudioConfig: ) self.pipeline_sample_rate = 16000 - # Log configuration for auditing - logger.info( - f"AudioConfig initialized: " - f"transport_in={self.transport_in_sample_rate}Hz, " - f"transport_out={self.transport_out_sample_rate}Hz, " - f"vad={self.vad_sample_rate}Hz, " - f"pipeline={self.pipeline_sample_rate}Hz, " - f"buffer={self.buffer_size_seconds}s" - ) - @property def buffer_size_bytes(self) -> int: """Calculate buffer size in bytes based on pipeline sample rate.""" diff --git a/api/services/pipecat/run_pipeline.py b/api/services/pipecat/run_pipeline.py index f99ada1d..713c0a2f 100644 --- a/api/services/pipecat/run_pipeline.py +++ b/api/services/pipecat/run_pipeline.py @@ -95,6 +95,9 @@ from pipecat.turns.user_start import ( MinWordsUserTurnStartStrategy, ProvisionalVADUserTurnStartStrategy, ) +from pipecat.turns.user_start.transcription_user_turn_start_strategy import ( + TranscriptionUserTurnStartStrategy, +) from pipecat.turns.user_start.vad_user_turn_start_strategy import ( VADUserTurnStartStrategy, ) @@ -160,9 +163,10 @@ def _create_non_realtime_user_turn_start_strategies( if turn_start_strategy == "provisional_vad": return [ + TranscriptionUserTurnStartStrategy(), ProvisionalVADUserTurnStartStrategy( pause_secs=_resolve_provisional_vad_pause_secs(run_configs) - ) + ), ] if uses_external_turns: @@ -172,7 +176,7 @@ def _create_non_realtime_user_turn_start_strategies( # confirms a real turn. return [ExternalUserTurnStartStrategy(enable_interruptions=True)] - return [VADUserTurnStartStrategy()] + return [TranscriptionUserTurnStartStrategy(), VADUserTurnStartStrategy()] def _create_non_realtime_user_turn_stop_strategies( diff --git a/api/services/pipecat/service_factory.py b/api/services/pipecat/service_factory.py index 54813fd4..e8a357a1 100644 --- a/api/services/pipecat/service_factory.py +++ b/api/services/pipecat/service_factory.py @@ -227,7 +227,6 @@ def create_stt_service( # Other models than flux # Use language from user config, defaulting to "multi" for multilingual support language = getattr(user_config.stt, "language", None) or "multi" - logger.debug(f"Using DeepGram Model - {user_config.stt.model}") return DeepgramSTTService( api_key=user_config.stt.api_key, settings=DeepgramSTTSettings( diff --git a/api/services/telephony/providers/cloudonix/provider.py b/api/services/telephony/providers/cloudonix/provider.py index 75d80e06..ff428589 100644 --- a/api/services/telephony/providers/cloudonix/provider.py +++ b/api/services/telephony/providers/cloudonix/provider.py @@ -1111,9 +1111,7 @@ class CloudonixProvider(TelephonyProvider): from_number = random.choice(self.from_numbers) backend_endpoint, _ = await get_backend_endpoints() - callback_url = ( - f"{backend_endpoint}/api/v1/telephony/cloudonix/transfer-result/{transfer_id}" - ) + callback_url = f"{backend_endpoint}/api/v1/telephony/cloudonix/transfer-result/{transfer_id}" endpoint = f"{self.base_url}/calls/{self.domain_id}/application" data: Dict[str, Any] = { @@ -1126,9 +1124,7 @@ class CloudonixProvider(TelephonyProvider): data.update(kwargs) headers = self._get_auth_headers() - masked_destination = ( - f"***{destination[-4:]}" if len(destination) > 4 else "***" - ) + masked_destination = f"***{destination[-4:]}" if len(destination) > 4 else "***" logger.info( f"[Cloudonix Transfer] Dialing {masked_destination} into conference " f"{conference_name} (transfer_id={transfer_id})" diff --git a/ui/src/app/workflow/[workflowId]/settings/page.tsx b/ui/src/app/workflow/[workflowId]/settings/page.tsx index 65a33c56..f6396ae0 100644 --- a/ui/src/app/workflow/[workflowId]/settings/page.tsx +++ b/ui/src/app/workflow/[workflowId]/settings/page.tsx @@ -647,6 +647,11 @@ function GeneralSection({
{selectedTurnStartStrategy?.description} + {turnStartStrategy === "provisional_vad" && ( + + Experimental + + )}
{turnStartStrategy === "min_words" && (