From 74aea65f17fa0faad365b41bd179470ba394c0ac Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= <aleix@daily.co>
Date: Tue, 30 Dec 2025 15:15:18 -0800
Subject: [PATCH] PipelineTask: use QueueTaskFrame

---
 src/pipecat/pipeline/task.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/pipecat/pipeline/task.py b/src/pipecat/pipeline/task.py
index 0c534a006..a1bdf53b4 100644
--- a/src/pipecat/pipeline/task.py
+++ b/src/pipecat/pipeline/task.py
@@ -35,6 +35,7 @@ from pipecat.frames.frames import (
     InterruptionFrame,
     InterruptionTaskFrame,
     MetricsFrame,
+    QueueTaskFrame,
     StartFrame,
     StopFrame,
     StopTaskFrame,
@@ -756,6 +757,9 @@ class PipelineTask(BasePipelineTask):
             # pipeline-ending frame to finish traversing the pipeline.
             logger.debug(f"{self}: received interruption task frame {frame}")
             await self._pipeline.queue_frame(InterruptionFrame())
+        elif isinstance(frame, QueueTaskFrame):
+            logger.debug(f"{self}: received queue task frame {frame}")
+            await self.queue_frames(frame.frames)
         elif isinstance(frame, ErrorFrame):
             await self._call_event_handler("on_pipeline_error", frame)
             if frame.fatal: