From c7ab87b0cc6f8122b0e691d38af388a9bcff04c8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 16 Jan 2026 10:52:23 -0800 Subject: [PATCH] turns: move mute to user_mute --- changelog/3479.deprecated.md | 1 + .../foundational/24-user-mute-strategy.py | 2 +- .../aggregators/llm_response_universal.py | 2 +- src/pipecat/turns/mute/__init__.py | 21 +++++++++++---- src/pipecat/turns/user_mute/__init__.py | 21 +++++++++++++++ .../always_user_mute_strategy.py | 2 +- .../base_user_mute_strategy.py | 0 .../first_speech_user_mute_strategy.py | 2 +- .../function_call_user_mute_strategy.py | 2 +- ...l_first_bot_complete_user_mute_strategy.py | 2 +- src/pipecat/turns/user_start/__init__.py | 26 ++++++++++--------- src/pipecat/turns/user_stop/__init__.py | 23 ++++++++-------- tests/test_context_aggregators_universal.py | 2 +- tests/test_user_mute_strategy.py | 2 +- 14 files changed, 72 insertions(+), 36 deletions(-) create mode 100644 changelog/3479.deprecated.md create mode 100644 src/pipecat/turns/user_mute/__init__.py rename src/pipecat/turns/{mute => user_mute}/always_user_mute_strategy.py (93%) rename src/pipecat/turns/{mute => user_mute}/base_user_mute_strategy.py (100%) rename src/pipecat/turns/{mute => user_mute}/first_speech_user_mute_strategy.py (96%) rename src/pipecat/turns/{mute => user_mute}/function_call_user_mute_strategy.py (95%) rename src/pipecat/turns/{mute => user_mute}/mute_until_first_bot_complete_user_mute_strategy.py (95%) diff --git a/changelog/3479.deprecated.md b/changelog/3479.deprecated.md new file mode 100644 index 000000000..7c58a9d89 --- /dev/null +++ b/changelog/3479.deprecated.md @@ -0,0 +1 @@ +- For consistency with other package names, we just deprecated `pipecat.turns.mute` (introduced in Pipecat 0.0.99) in favor of `pipecat.turns.user_mute`. diff --git a/examples/foundational/24-user-mute-strategy.py b/examples/foundational/24-user-mute-strategy.py index df6619fd4..00e1ff66a 100644 --- a/examples/foundational/24-user-mute-strategy.py +++ b/examples/foundational/24-user-mute-strategy.py @@ -34,7 +34,7 @@ from pipecat.services.openai.llm import OpenAILLMService from pipecat.transports.base_transport import BaseTransport, TransportParams from pipecat.transports.daily.transport import DailyParams from pipecat.transports.websocket.fastapi import FastAPIWebsocketParams -from pipecat.turns.mute import ( +from pipecat.turns.user_mute import ( FunctionCallUserMuteStrategy, MuteUntilFirstBotCompleteUserMuteStrategy, ) diff --git a/src/pipecat/processors/aggregators/llm_response_universal.py b/src/pipecat/processors/aggregators/llm_response_universal.py index 2854c8681..26c388fe6 100644 --- a/src/pipecat/processors/aggregators/llm_response_universal.py +++ b/src/pipecat/processors/aggregators/llm_response_universal.py @@ -62,7 +62,7 @@ from pipecat.processors.aggregators.llm_context import ( NotGiven, ) from pipecat.processors.frame_processor import FrameDirection, FrameProcessor -from pipecat.turns.mute import BaseUserMuteStrategy +from pipecat.turns.user_mute import BaseUserMuteStrategy from pipecat.turns.user_start import BaseUserTurnStartStrategy, UserTurnStartedParams from pipecat.turns.user_stop import BaseUserTurnStopStrategy, UserTurnStoppedParams from pipecat.turns.user_turn_controller import UserTurnController diff --git a/src/pipecat/turns/mute/__init__.py b/src/pipecat/turns/mute/__init__.py index d452ce19e..02b66688f 100644 --- a/src/pipecat/turns/mute/__init__.py +++ b/src/pipecat/turns/mute/__init__.py @@ -4,10 +4,21 @@ # SPDX-License-Identifier: BSD 2-Clause License # -from pipecat.turns.mute.always_user_mute_strategy import AlwaysUserMuteStrategy -from pipecat.turns.mute.base_user_mute_strategy import BaseUserMuteStrategy -from pipecat.turns.mute.first_speech_user_mute_strategy import FirstSpeechUserMuteStrategy -from pipecat.turns.mute.function_call_user_mute_strategy import FunctionCallUserMuteStrategy -from pipecat.turns.mute.mute_until_first_bot_complete_user_mute_strategy import ( +import warnings + +from pipecat.turns.user_mute.always_user_mute_strategy import AlwaysUserMuteStrategy +from pipecat.turns.user_mute.base_user_mute_strategy import BaseUserMuteStrategy +from pipecat.turns.user_mute.first_speech_user_mute_strategy import FirstSpeechUserMuteStrategy +from pipecat.turns.user_mute.function_call_user_mute_strategy import FunctionCallUserMuteStrategy +from pipecat.turns.user_mute.mute_until_first_bot_complete_user_mute_strategy import ( MuteUntilFirstBotCompleteUserMuteStrategy, ) + +with warnings.catch_warnings(): + warnings.simplefilter("always") + warnings.warn( + "Types in pipecat.turns.mute are deprecated. " + "Please use the equivalent types from pipecat.turns.user_mute instead.", + DeprecationWarning, + stacklevel=2, + ) diff --git a/src/pipecat/turns/user_mute/__init__.py b/src/pipecat/turns/user_mute/__init__.py new file mode 100644 index 000000000..14c5fea42 --- /dev/null +++ b/src/pipecat/turns/user_mute/__init__.py @@ -0,0 +1,21 @@ +# +# Copyright (c) 2024-2026, Daily +# +# SPDX-License-Identifier: BSD 2-Clause License +# + +from .always_user_mute_strategy import AlwaysUserMuteStrategy +from .base_user_mute_strategy import BaseUserMuteStrategy +from .first_speech_user_mute_strategy import FirstSpeechUserMuteStrategy +from .function_call_user_mute_strategy import FunctionCallUserMuteStrategy +from .mute_until_first_bot_complete_user_mute_strategy import ( + MuteUntilFirstBotCompleteUserMuteStrategy, +) + +__all__ = [ + "AlwaysUserMuteStrategy", + "BaseUserMuteStrategy", + "FirstSpeechUserMuteStrategy", + "FunctionCallUserMuteStrategy", + "MuteUntilFirstBotCompleteUserMuteStrategy", +] diff --git a/src/pipecat/turns/mute/always_user_mute_strategy.py b/src/pipecat/turns/user_mute/always_user_mute_strategy.py similarity index 93% rename from src/pipecat/turns/mute/always_user_mute_strategy.py rename to src/pipecat/turns/user_mute/always_user_mute_strategy.py index 584b8165b..981c6bb74 100644 --- a/src/pipecat/turns/mute/always_user_mute_strategy.py +++ b/src/pipecat/turns/user_mute/always_user_mute_strategy.py @@ -7,7 +7,7 @@ """User mute strategy that always mutes the user while the bot is speaking.""" from pipecat.frames.frames import BotStartedSpeakingFrame, BotStoppedSpeakingFrame, Frame -from pipecat.turns.mute.base_user_mute_strategy import BaseUserMuteStrategy +from pipecat.turns.user_mute.base_user_mute_strategy import BaseUserMuteStrategy class AlwaysUserMuteStrategy(BaseUserMuteStrategy): diff --git a/src/pipecat/turns/mute/base_user_mute_strategy.py b/src/pipecat/turns/user_mute/base_user_mute_strategy.py similarity index 100% rename from src/pipecat/turns/mute/base_user_mute_strategy.py rename to src/pipecat/turns/user_mute/base_user_mute_strategy.py diff --git a/src/pipecat/turns/mute/first_speech_user_mute_strategy.py b/src/pipecat/turns/user_mute/first_speech_user_mute_strategy.py similarity index 96% rename from src/pipecat/turns/mute/first_speech_user_mute_strategy.py rename to src/pipecat/turns/user_mute/first_speech_user_mute_strategy.py index 1ce4c64f5..9349edd11 100644 --- a/src/pipecat/turns/mute/first_speech_user_mute_strategy.py +++ b/src/pipecat/turns/user_mute/first_speech_user_mute_strategy.py @@ -7,7 +7,7 @@ """User mute strategy that mutes the user only during the bot’s first speech.""" from pipecat.frames.frames import BotStartedSpeakingFrame, BotStoppedSpeakingFrame, Frame -from pipecat.turns.mute.base_user_mute_strategy import BaseUserMuteStrategy +from pipecat.turns.user_mute.base_user_mute_strategy import BaseUserMuteStrategy class FirstSpeechUserMuteStrategy(BaseUserMuteStrategy): diff --git a/src/pipecat/turns/mute/function_call_user_mute_strategy.py b/src/pipecat/turns/user_mute/function_call_user_mute_strategy.py similarity index 95% rename from src/pipecat/turns/mute/function_call_user_mute_strategy.py rename to src/pipecat/turns/user_mute/function_call_user_mute_strategy.py index ef83de271..f50f31bd4 100644 --- a/src/pipecat/turns/mute/function_call_user_mute_strategy.py +++ b/src/pipecat/turns/user_mute/function_call_user_mute_strategy.py @@ -14,7 +14,7 @@ from pipecat.frames.frames import ( FunctionCallResultFrame, FunctionCallsStartedFrame, ) -from pipecat.turns.mute.base_user_mute_strategy import BaseUserMuteStrategy +from pipecat.turns.user_mute.base_user_mute_strategy import BaseUserMuteStrategy class FunctionCallUserMuteStrategy(BaseUserMuteStrategy): diff --git a/src/pipecat/turns/mute/mute_until_first_bot_complete_user_mute_strategy.py b/src/pipecat/turns/user_mute/mute_until_first_bot_complete_user_mute_strategy.py similarity index 95% rename from src/pipecat/turns/mute/mute_until_first_bot_complete_user_mute_strategy.py rename to src/pipecat/turns/user_mute/mute_until_first_bot_complete_user_mute_strategy.py index 6ac5d62a9..20fe7016a 100644 --- a/src/pipecat/turns/mute/mute_until_first_bot_complete_user_mute_strategy.py +++ b/src/pipecat/turns/user_mute/mute_until_first_bot_complete_user_mute_strategy.py @@ -7,7 +7,7 @@ """User mute strategy that mutes the user until the bot completes its first speech.""" from pipecat.frames.frames import BotStoppedSpeakingFrame, Frame -from pipecat.turns.mute.base_user_mute_strategy import BaseUserMuteStrategy +from pipecat.turns.user_mute.base_user_mute_strategy import BaseUserMuteStrategy class MuteUntilFirstBotCompleteUserMuteStrategy(BaseUserMuteStrategy): diff --git a/src/pipecat/turns/user_start/__init__.py b/src/pipecat/turns/user_start/__init__.py index 3108e1c9a..fb84f62ed 100644 --- a/src/pipecat/turns/user_start/__init__.py +++ b/src/pipecat/turns/user_start/__init__.py @@ -4,15 +4,17 @@ # SPDX-License-Identifier: BSD 2-Clause License # -from pipecat.turns.user_start.base_user_turn_start_strategy import ( - BaseUserTurnStartStrategy, - UserTurnStartedParams, -) -from pipecat.turns.user_start.external_user_turn_start_strategy import ExternalUserTurnStartStrategy -from pipecat.turns.user_start.min_words_user_turn_start_strategy import ( - MinWordsUserTurnStartStrategy, -) -from pipecat.turns.user_start.transcription_user_turn_start_strategy import ( - TranscriptionUserTurnStartStrategy, -) -from pipecat.turns.user_start.vad_user_turn_start_strategy import VADUserTurnStartStrategy +from .base_user_turn_start_strategy import BaseUserTurnStartStrategy, UserTurnStartedParams +from .external_user_turn_start_strategy import ExternalUserTurnStartStrategy +from .min_words_user_turn_start_strategy import MinWordsUserTurnStartStrategy +from .transcription_user_turn_start_strategy import TranscriptionUserTurnStartStrategy +from .vad_user_turn_start_strategy import VADUserTurnStartStrategy + +__all__ = [ + "BaseUserTurnStartStrategy", + "ExternalUserTurnStartStrategy", + "MinWordsUserTurnStartStrategy", + "TranscriptionUserTurnStartStrategy", + "UserTurnStartedParams", + "VADUserTurnStartStrategy", +] diff --git a/src/pipecat/turns/user_stop/__init__.py b/src/pipecat/turns/user_stop/__init__.py index f54e00b7e..b95a71d15 100644 --- a/src/pipecat/turns/user_stop/__init__.py +++ b/src/pipecat/turns/user_stop/__init__.py @@ -4,14 +4,15 @@ # SPDX-License-Identifier: BSD 2-Clause License # -from pipecat.turns.user_stop.base_user_turn_stop_strategy import ( - BaseUserTurnStopStrategy, - UserTurnStoppedParams, -) -from pipecat.turns.user_stop.external_user_turn_stop_strategy import ExternalUserTurnStopStrategy -from pipecat.turns.user_stop.transcription_user_turn_stop_strategy import ( - TranscriptionUserTurnStopStrategy, -) -from pipecat.turns.user_stop.turn_analyzer_user_turn_stop_strategy import ( - TurnAnalyzerUserTurnStopStrategy, -) +from .base_user_turn_stop_strategy import BaseUserTurnStopStrategy, UserTurnStoppedParams +from .external_user_turn_stop_strategy import ExternalUserTurnStopStrategy +from .transcription_user_turn_stop_strategy import TranscriptionUserTurnStopStrategy +from .turn_analyzer_user_turn_stop_strategy import TurnAnalyzerUserTurnStopStrategy + +__all__ = [ + "BaseUserTurnStopStrategy", + "ExternalUserTurnStopStrategy", + "UserTurnStoppedParams", + "TranscriptionUserTurnStopStrategy", + "TurnAnalyzerUserTurnStopStrategy", +] diff --git a/tests/test_context_aggregators_universal.py b/tests/test_context_aggregators_universal.py index 6aa38d362..3cb1407f1 100644 --- a/tests/test_context_aggregators_universal.py +++ b/tests/test_context_aggregators_universal.py @@ -40,7 +40,7 @@ from pipecat.processors.aggregators.llm_response_universal import ( LLMUserAggregatorParams, ) from pipecat.tests.utils import SleepFrame, run_test -from pipecat.turns.mute import FirstSpeechUserMuteStrategy, FunctionCallUserMuteStrategy +from pipecat.turns.user_mute import FirstSpeechUserMuteStrategy, FunctionCallUserMuteStrategy from pipecat.turns.user_stop import TranscriptionUserTurnStopStrategy from pipecat.turns.user_turn_strategies import UserTurnStrategies diff --git a/tests/test_user_mute_strategy.py b/tests/test_user_mute_strategy.py index 26a7af1cc..d8261877e 100644 --- a/tests/test_user_mute_strategy.py +++ b/tests/test_user_mute_strategy.py @@ -15,7 +15,7 @@ from pipecat.frames.frames import ( FunctionCallsStartedFrame, InterruptionFrame, ) -from pipecat.turns.mute import ( +from pipecat.turns.user_mute import ( AlwaysUserMuteStrategy, FirstSpeechUserMuteStrategy, FunctionCallUserMuteStrategy,