BaseTransportOutput: allow pushing frames upstream

2025-02-13 13:17:57 -08:00
parent b28f752afa
commit 67cdc0063a
2 changed files with 5 additions and 0 deletions
--- a/src/pipecat/transports/base_output.py
+++ b/src/pipecat/transports/base_output.py
@@ -170,6 +170,8 @@ class BaseOutputTransport(FrameProcessor):
        # TODO(aleix): Images and audio should support presentation timestamps.
        elif frame.pts:
            await self._sink_clock_queue.put((frame.pts, frame.id, frame))
+        elif direction == FrameDirection.UPSTREAM:
+            await self.push_frame(frame, direction)
        else:
            await self._sink_queue.put(frame)