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.