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."""