From 935eb589511bbded83adcca745159122e6602d2a Mon Sep 17 00:00:00 2001 From: Toprak2 Date: Thu, 6 Nov 2025 19:18:15 +0300 Subject: [PATCH 1/2] Update docstring for FrameProcessorQueue Clarify the docstring for FrameProcessorQueue initialization. --- src/pipecat/processors/frame_processor.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index 1ca3333b5..0f9b6b08b 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -84,10 +84,10 @@ class FrameProcessorQueue(asyncio.PriorityQueue): def __init__(self): """Initialize the FrameProcessorQueue. - - Args: - manager (BaseTaskManager): The task manager used by the internal watchdog queues. - + + Creates a priority queue with separate counters for high and low priority + items to maintain insertion order within each priority level. + """ super().__init__() self.__high_counter = 0 From 2ab6b718909b549f545e4c242828c9105559c41e Mon Sep 17 00:00:00 2001 From: Muhammed Ali Toprak Date: Fri, 7 Nov 2025 11:24:06 +0300 Subject: [PATCH 2/2] Shorten docstring for clarity --- src/pipecat/processors/frame_processor.py | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index f5d7db8e5..69aee0acd 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -83,12 +83,7 @@ class FrameProcessorQueue(asyncio.PriorityQueue): LOW_PRIORITY = 2 def __init__(self): - """Initialize the FrameProcessorQueue. - - Creates a priority queue with separate counters for high and low priority - items to maintain insertion order within each priority level. - - """ + """Initialize the FrameProcessorQueue.""" super().__init__() self.__high_counter = 0 self.__low_counter = 0