From 7913d4e1886c8c3623412d9c5db11d359bfd0d23 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Mon, 30 Mar 2026 14:45:42 -0700 Subject: [PATCH] FrameProcessor: remove deprecated wait_for_task() --- src/pipecat/processors/frame_processor.py | 27 ----------------------- 1 file changed, 27 deletions(-) diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index f3d9fbdea..8efb1353d 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -527,33 +527,6 @@ class FrameProcessor(BaseObject): """ await self.task_manager.cancel_task(task, timeout) - async def wait_for_task(self, task: asyncio.Task, timeout: Optional[float] = None): - """Wait for a task to complete. - - .. deprecated:: 0.0.81 - This function is deprecated, use `await task` or - `await asyncio.wait_for(task, timeout)` instead. - - Args: - task: The task to wait for. - timeout: Optional timeout for waiting. - """ - import warnings - - with warnings.catch_warnings(): - warnings.simplefilter("always") - warnings.warn( - "`FrameProcessor.wait_for_task()` is deprecated. " - "Use `await task` or `await asyncio.wait_for(task, timeout)` instead.", - DeprecationWarning, - stacklevel=2, - ) - - if timeout: - await asyncio.wait_for(task, timeout) - else: - await task - async def setup(self, setup: FrameProcessorSetup): """Set up the processor with required components.