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

transports(base_output): fix duplicate push_frame()

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-12-22 14:35:01 -08:00
parent 9c105e25ac
commit c04c69df95
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/pipecat/transports/base_output.py
View File

@@ -242,8 +242,6 @@ class BaseOutputTransport(FrameProcessor):
await self._set_camera_images(frame.images) await self._set_camera_images(frame.images)
elif isinstance(frame, TransportMessageFrame): elif isinstance(frame, TransportMessageFrame):
await self.send_message(frame) await self.send_message(frame)
else:
await self.push_frame(frame)
async def _sink_clock_task_handler(self): async def _sink_clock_task_handler(self):
running = True running = True
@@ -262,8 +260,13 @@ class BaseOutputTransport(FrameProcessor):
if timestamp > current_time: if timestamp > current_time:
wait_time = nanoseconds_to_seconds(timestamp - current_time) wait_time = nanoseconds_to_seconds(timestamp - current_time)
await asyncio.sleep(wait_time) await asyncio.sleep(wait_time)
# Handle frame.
await self._sink_frame_handler(frame) 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() self._sink_clock_queue.task_done()
except asyncio.CancelledError: except asyncio.CancelledError:
break break