diff --git a/src/pipecat/frames/frames.py b/src/pipecat/frames/frames.py index 86a93825b..f3866cf3a 100644 --- a/src/pipecat/frames/frames.py +++ b/src/pipecat/frames/frames.py @@ -1092,7 +1092,6 @@ class UserImageRequestFrame(SystemFrame): function_name: Name of function that generated this request (if any). tool_call_id: Tool call ID if generated by function call (if any). result_callback: Optional callback to invoke when the image is retrieved. - context: [DEPRECATED] Optional context for the image request. """ user_id: str @@ -1102,21 +1101,6 @@ class UserImageRequestFrame(SystemFrame): function_name: Optional[str] = None tool_call_id: Optional[str] = None result_callback: Optional[Any] = None - context: Optional[Any] = None - - def __post_init__(self): - super().__post_init__() - - if self.context: - import warnings - - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "`UserImageRequestFrame` field `context` is deprecated.", - DeprecationWarning, - stacklevel=2, - ) def __str__(self): return f"{self.name}(user: {self.user_id}, text: {self.text}, append_to_context: {self.append_to_context}, {self.video_source})" diff --git a/src/pipecat/pipeline/task_observer.py b/src/pipecat/pipeline/task_observer.py index dc2040e07..84f463443 100644 --- a/src/pipecat/pipeline/task_observer.py +++ b/src/pipecat/pipeline/task_observer.py @@ -12,7 +12,6 @@ the main pipeline execution. """ import asyncio -import inspect from typing import Any, Dict, List, Optional from attr import dataclass @@ -179,32 +178,13 @@ class TaskObserver(BaseObserver): async def _proxy_task_handler(self, queue: asyncio.Queue, observer: BaseObserver): """Handle frame processing for a single observer.""" - on_push_frame_deprecated = False - signature = inspect.signature(observer.on_push_frame) - if len(signature.parameters) > 1: - import warnings - - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "Observer `on_push_frame(source, destination, frame, direction, timestamp)` is deprecated, us `on_push_frame(data: FramePushed)` instead.", - DeprecationWarning, - ) - - on_push_frame_deprecated = True - while True: data = await queue.get() if isinstance(data, _PipelineStartedSignal): await observer.on_pipeline_started() elif isinstance(data, FramePushed): - if on_push_frame_deprecated: - await observer.on_push_frame( - data.source, data.destination, data.frame, data.direction, data.timestamp - ) - else: - await observer.on_push_frame(data) + await observer.on_push_frame(data) elif isinstance(data, FrameProcessed): await observer.on_process_frame(data) diff --git a/src/pipecat/processors/aggregators/llm_response_universal.py b/src/pipecat/processors/aggregators/llm_response_universal.py index 911035fdc..968d76778 100644 --- a/src/pipecat/processors/aggregators/llm_response_universal.py +++ b/src/pipecat/processors/aggregators/llm_response_universal.py @@ -127,10 +127,6 @@ class LLMAssistantAggregatorParams: """Parameters for configuring LLM assistant aggregation behavior. Parameters: - expect_stripped_words: Whether to expect and handle stripped words - in text frames by adding spaces between tokens. This parameter is - ignored when used with the newer LLMAssistantAggregator, which - handles word spacing automatically. enable_auto_context_summarization: Enable automatic context summarization when token or message-count limits are reached (disabled by default). When enabled, older conversation messages are automatically compressed into summaries to @@ -141,7 +137,6 @@ class LLMAssistantAggregatorParams: ``LLMAutoContextSummarizationConfig`` values. """ - expect_stripped_words: bool = True enable_auto_context_summarization: bool = False auto_context_summarization_config: Optional[LLMAutoContextSummarizationConfig] = None @@ -813,26 +808,6 @@ class LLMAssistantAggregator(LLMContextAggregator): super().__init__(context=context, role="assistant", **kwargs) self._params = params or LLMAssistantAggregatorParams() - if "expect_stripped_words" in kwargs: - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "Parameter 'expect_stripped_words' is deprecated. " - "LLMAssistantAggregator now handles word spacing automatically.", - DeprecationWarning, - ) - - self._params.expect_stripped_words = kwargs["expect_stripped_words"] - - if params and not params.expect_stripped_words: - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "params.expect_stripped_words is deprecated. " - "LLMAssistantAggregator now handles word spacing automatically.", - DeprecationWarning, - ) - self._function_calls_in_progress: Dict[str, Optional[FunctionCallInProgressFrame]] = {} self._function_calls_image_results: Dict[str, UserImageRawFrame] = {} self._context_updated_tasks: Set[asyncio.Task] = set() diff --git a/src/pipecat/transports/livekit/transport.py b/src/pipecat/transports/livekit/transport.py index dfb7e0565..f3b0574b8 100644 --- a/src/pipecat/transports/livekit/transport.py +++ b/src/pipecat/transports/livekit/transport.py @@ -92,50 +92,6 @@ class LiveKitOutputTransportMessageUrgentFrame(OutputTransportMessageUrgentFrame participant_id: Optional[str] = None -@dataclass -class LiveKitTransportMessageFrame(LiveKitOutputTransportMessageFrame): - """Frame for transport messages in LiveKit rooms. - - Parameters: - participant_id: Optional ID of the participant this message is for/from. - """ - - def __post_init__(self): - super().__post_init__() - import warnings - - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "LiveKitTransportMessageFrame is deprecated and will be removed in a future version. " - "Instead, use LiveKitOutputTransportMessageFrame.", - DeprecationWarning, - stacklevel=2, - ) - - -@dataclass -class LiveKitTransportMessageUrgentFrame(LiveKitOutputTransportMessageUrgentFrame): - """Frame for urgent transport messages in LiveKit rooms. - - Parameters: - participant_id: Optional ID of the participant this message is for/from. - """ - - def __post_init__(self): - super().__post_init__() - import warnings - - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "LiveKitTransportMessageUrgentFrame is deprecated and will be removed in a future version. " - "Instead, use LiveKitOutputTransportMessageUrgentFrame.", - DeprecationWarning, - stacklevel=2, - ) - - class LiveKitParams(TransportParams): """Configuration parameters for LiveKit transport. diff --git a/src/pipecat/turns/mute/__init__.py b/src/pipecat/turns/mute/__init__.py deleted file mode 100644 index c82b10ae7..000000000 --- a/src/pipecat/turns/mute/__init__.py +++ /dev/null @@ -1,32 +0,0 @@ -# -# Copyright (c) 2024-2026, Daily -# -# SPDX-License-Identifier: BSD 2-Clause License -# - -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, - ) - -__all__ = [ - "AlwaysUserMuteStrategy", - "BaseUserMuteStrategy", - "FirstSpeechUserMuteStrategy", - "FunctionCallUserMuteStrategy", - "MuteUntilFirstBotCompleteUserMuteStrategy", -]