From a9e565f3550fcdf01652a52d3bfc75bb66414d2d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Wed, 6 Nov 2024 13:12:24 -0800 Subject: [PATCH] processors: fix input queue interruptions --- src/pipecat/processors/frame_processor.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index 007c80c9e..04f53f127 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -217,18 +217,18 @@ class FrameProcessor: # async def _start_interruption(self): - # Cancel the input task. This will stop processing queued frames. - await self.__cancel_input_task() - # Cancel the push frame task. This will stop pushing frames downstream. await self.__cancel_push_task() - # Create a new output queue and task. - self.__create_push_task() + # Cancel the input task. This will stop processing queued frames. + await self.__cancel_input_task() # Create a new input queue and task. self.__create_input_task() + # Create a new output queue and task. + self.__create_push_task() + async def _stop_interruption(self): # Nothing to do right now. pass