Skip to content

Commit 4a9eb82

Browse files
committed
fix: preserve UninterruptibleFrames in __reset_process_queue
1 parent 829c5f4 commit 4a9eb82

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/pipecat/processors/frame_processor.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -950,7 +950,8 @@ def __reset_process_queue(self):
950950
# Process current queue and keep UninterruptibleFrame frames.
951951
while not self.__process_queue.empty():
952952
item = self.__process_queue.get_nowait()
953-
if isinstance(item, UninterruptibleFrame):
953+
frame = item[0]
954+
if isinstance(frame, UninterruptibleFrame):
954955
new_queue.put_nowait(item)
955956
self.__process_queue.task_done()
956957

0 commit comments

Comments
 (0)