fix user transcript event ordering

2026-06-01 09:28:34 +08:00
parent 8a39461b21
commit d62c564a0d
1 changed files with 1 additions and 1 deletions
--- a/engine/pipeline.py
+++ b/engine/pipeline.py
@@ -250,7 +250,7 @@ async def run_pipeline_with_serializer(
        text = (message.content or "").strip()
        if not text:
            return
-        await task.queue_frame(
+        await _aggregator.push_frame(
            OutputTransportMessageUrgentFrame(
                message={
                    "type": "input.transcript.final",