diff --git a/engine/pipeline.py b/engine/pipeline.py
index 252ee3e..302f352 100644
--- 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",