wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cleared input and process events when pausing (#2698)

Browse Source
This commit is contained in:
chadbailey59
2025-09-19 16:44:43 -05:00
committed by GitHub
parent 9027a96a07
commit 3984cb58a2
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/processors/frame_processor.py
View File

@@ -568,11 +568,15 @@ class FrameProcessor(BaseObject):
"""Pause processing of queued frames.""" """Pause processing of queued frames."""
logger.trace(f"{self}: pausing frame processing") logger.trace(f"{self}: pausing frame processing")
self.__should_block_frames = True self.__should_block_frames = True
if self.__process_event:
self.__process_event.clear()
async def pause_processing_system_frames(self): async def pause_processing_system_frames(self):
"""Pause processing of queued system frames.""" """Pause processing of queued system frames."""
logger.trace(f"{self}: pausing system frame processing") logger.trace(f"{self}: pausing system frame processing")
self.__should_block_system_frames = True self.__should_block_system_frames = True
if self.__input_event:
self.__input_event.clear()
async def resume_processing_frames(self): async def resume_processing_frames(self):
"""Resume processing of queued frames.""" """Resume processing of queued frames."""