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

FrameProcessor: no need to create an input event every time

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-02-14 16:42:00 -08:00
parent 1f5b790dd0
commit 883410d8ac
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -73,10 +73,11 @@ class FrameProcessor:
self._metrics.set_processor_name(self.name) self._metrics.set_processor_name(self.name)
# Processors have an input queue. The input queue will be processed # Processors have an input queue. The input queue will be processed
# immediately (default) or it will block if `pause_processing_frames()` is # immediately (default) or it will block if `pause_processing_frames()`
# called. To resume processing frames we need to call # is called. To resume processing frames we need to call
# `resume_processing_frames()`. # `resume_processing_frames()` which will wake up the event.
self.__should_block_frames = False self.__should_block_frames = False
self.__input_event = asyncio.Event()
self.__input_frame_task: Optional[asyncio.Task] = None self.__input_frame_task: Optional[asyncio.Task] = None
# Every processor in Pipecat should only output frames from a single # Every processor in Pipecat should only output frames from a single
@@ -335,8 +336,8 @@ class FrameProcessor:
def __create_input_task(self): def __create_input_task(self):
if not self.__input_frame_task: if not self.__input_frame_task:
self.__should_block_frames = False self.__should_block_frames = False
self.__input_event.clear()
self.__input_queue = asyncio.Queue() self.__input_queue = asyncio.Queue()
self.__input_event = asyncio.Event()
self.__input_frame_task = self.create_task(self.__input_frame_task_handler()) self.__input_frame_task = self.create_task(self.__input_frame_task_handler())
async def __cancel_input_task(self): async def __cancel_input_task(self):