Merge pull request #3494 from omChauhanDev/fix/uninterruptible-frame-handling

fix: preserve UninterruptibleFrames in __reset_process_queue
2026-01-20 13:19:40 -08:00
parent 03faadd7f9 4a9eb82f92
commit a266644b06
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()