wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

PipelineTask: use QueueTaskFrame

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-12-30 15:15:18 -08:00
parent bd7b24596e
commit 74aea65f17
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/pipeline/task.py
View File

@@ -35,6 +35,7 @@ from pipecat.frames.frames import (
InterruptionFrame, InterruptionFrame,
InterruptionTaskFrame, InterruptionTaskFrame,
MetricsFrame, MetricsFrame,
QueueTaskFrame,
StartFrame, StartFrame,
StopFrame, StopFrame,
StopTaskFrame, StopTaskFrame,
@@ -756,6 +757,9 @@ class PipelineTask(BasePipelineTask):
# pipeline-ending frame to finish traversing the pipeline. # pipeline-ending frame to finish traversing the pipeline.
logger.debug(f"{self}: received interruption task frame {frame}") logger.debug(f"{self}: received interruption task frame {frame}")
await self._pipeline.queue_frame(InterruptionFrame()) 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): elif isinstance(frame, ErrorFrame):
await self._call_event_handler("on_pipeline_error", frame) await self._call_event_handler("on_pipeline_error", frame)
if frame.fatal: if frame.fatal: