From ba64f126a3b823e6902970e50fa647d255e12018 Mon Sep 17 00:00:00 2001 From: Chad Bailey Date: Fri, 19 Sep 2025 18:10:38 +0000 Subject: [PATCH] reset paused frame processors after interruption --- src/pipecat/processors/frame_processor.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index 85ce18548..2463144f2 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -568,11 +568,17 @@ class FrameProcessor(BaseObject): """Pause processing of queued frames.""" logger.trace(f"{self}: pausing frame processing") self.__should_block_frames = True + # We should also unset the process event here, in case it was set immediately after an interruption + if self.__process_event: + self.__process_event.clear() async def pause_processing_system_frames(self): """Pause processing of queued system frames.""" logger.trace(f"{self}: pausing system frame processing") self.__should_block_system_frames = True + # We should also unset the input event here, in case it was set immediately after an interruption + if self.__input_event: + self.__input_event.clear() async def resume_processing_frames(self): """Resume processing of queued frames."""