From bd7b24596e0f418128cb5b036eed60f7955e8066 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Tue, 30 Dec 2025 15:15:04 -0800 Subject: [PATCH] frames: add QueueTaskFrame --- src/pipecat/frames/frames.py | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/src/pipecat/frames/frames.py b/src/pipecat/frames/frames.py index 52b7ef896..535cad926 100644 --- a/src/pipecat/frames/frames.py +++ b/src/pipecat/frames/frames.py @@ -1653,6 +1653,18 @@ class InterruptionTaskFrame(TaskFrame): pass +@dataclass +class QueueTaskFrame(TaskFrame): + """Frame to request the pipeline task to push the included frames. + + This is useful when you want the push frames from upstream down to the + pipeline. Pushing this frame upstream guarantees upstream frame ordering. + + """ + + frames: Sequence[Frame] + + @dataclass class BotInterruptionFrame(InterruptionTaskFrame): """Frame indicating the bot should be interrupted.