From 3984cb58a2a8a1d63338fd9a63d9fa8b485bb6b9 Mon Sep 17 00:00:00 2001 From: chadbailey59 Date: Fri, 19 Sep 2025 16:44:43 -0500 Subject: [PATCH] cleared input and process events when pausing (#2698) --- src/pipecat/processors/frame_processor.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index 85ce18548..5723512a3 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -568,11 +568,15 @@ class FrameProcessor(BaseObject): """Pause processing of queued frames.""" logger.trace(f"{self}: pausing frame processing") self.__should_block_frames = True + 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 + if self.__input_event: + self.__input_event.clear() async def resume_processing_frames(self): """Resume processing of queued frames."""