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

transports(base): always send MetricsFrame

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-06-12 11:34:25 -07:00
parent 71e1d0a334
commit 0225443ec8
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -135,6 +135,9 @@ class BaseOutputTransport(FrameProcessor):
elif isinstance(frame, StartInterruptionFrame) or isinstance(frame, StopInterruptionFrame): elif isinstance(frame, StartInterruptionFrame) or isinstance(frame, StopInterruptionFrame):
await self._handle_interruptions(frame) await self._handle_interruptions(frame)
await self.push_frame(frame, direction) await self.push_frame(frame, direction)
elif isinstance(frame, MetricsFrame):
self.send_metrics(frame)
await self.push_frame(frame, direction)
elif isinstance(frame, SystemFrame): elif isinstance(frame, SystemFrame):
await self.push_frame(frame, direction) await self.push_frame(frame, direction)
elif isinstance(frame, AudioRawFrame): elif isinstance(frame, AudioRawFrame):
@@ -182,8 +185,6 @@ class BaseOutputTransport(FrameProcessor):
self._set_camera_images(frame.images) self._set_camera_images(frame.images)
elif isinstance(frame, TransportMessageFrame): elif isinstance(frame, TransportMessageFrame):
self.send_message(frame) self.send_message(frame)
elif isinstance(frame, MetricsFrame):
self.send_metrics(frame)
else: else:
future = asyncio.run_coroutine_threadsafe( future = asyncio.run_coroutine_threadsafe(
self._internal_push_frame(frame), self.get_event_loop()) self._internal_push_frame(frame), self.get_event_loop())