fix: preserve UninterruptibleFrames in __reset_process_queue

2026-01-18 20:39:13 +05:30
parent 829c5f4604
commit 4a9eb82f92
1 changed files with 2 additions and 1 deletions
--- a/src/pipecat/processors/frame_processor.py
+++ b/src/pipecat/processors/frame_processor.py
@@ -950,7 +950,8 @@ class FrameProcessor(BaseObject):
        # Process current queue and keep UninterruptibleFrame frames.
        while not self.__process_queue.empty():
            item = self.__process_queue.get_nowait()
-            if isinstance(item, UninterruptibleFrame):
+            frame = item[0]
+            if isinstance(frame, UninterruptibleFrame):
                new_queue.put_nowait(item)
            self.__process_queue.task_done()