transports(base_output): fix duplicate push_frame()

pipecat-ai · Dec 22, 2024 · 1d4bab5 · 1d4bab5
1 parent 9c105e2
commit 1d4bab5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py
@@ -242,8 +242,6 @@ async def _sink_frame_handler(self, frame: Frame):
             await self._set_camera_images(frame.images)
         elif isinstance(frame, TransportMessageFrame):
             await self.send_message(frame)
-        else:
-            await self.push_frame(frame)
 
     async def _sink_clock_task_handler(self):
         running = True
@@ -264,6 +262,9 @@ async def _sink_clock_task_handler(self):
                         await asyncio.sleep(wait_time)
                     await self._sink_frame_handler(frame)
 
+                    # Also, push frame downstream in case anyone else needs it.
+                    await self.push_frame(frame)
+
                 self._sink_clock_queue.task_done()
             except asyncio.CancelledError:
                 break