From a6a49109319e6ae53bc48ddbb75fd4cb82434213 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Tue, 3 Dec 2024 10:48:50 -0800 Subject: [PATCH] transports(services): incoming transport messages should be urgent --- src/pipecat/transports/services/daily.py | 2 +- src/pipecat/transports/services/livekit.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py index 7b0cd6c00..a5936e80a 100644 --- a/src/pipecat/transports/services/daily.py +++ b/src/pipecat/transports/services/daily.py @@ -723,7 +723,7 @@ class DailyInputTransport(BaseInputTransport): await self.push_frame(frame) async def push_app_message(self, message: Any, sender: str): - frame = DailyTransportMessageFrame(message=message, participant_id=sender) + frame = DailyTransportMessageUrgentFrame(message=message, participant_id=sender) await self.push_frame(frame) # diff --git a/src/pipecat/transports/services/livekit.py b/src/pipecat/transports/services/livekit.py index 5d4fbdd6c..6c99f6a66 100644 --- a/src/pipecat/transports/services/livekit.py +++ b/src/pipecat/transports/services/livekit.py @@ -342,7 +342,7 @@ class LiveKitInputTransport(BaseInputTransport): return self._vad_analyzer async def push_app_message(self, message: Any, sender: str): - frame = LiveKitTransportMessageFrame(message=message, participant_id=sender) + frame = LiveKitTransportMessageUrgentFrame(message=message, participant_id=sender) await self.push_frame(frame) async def _audio_in_task_handler(self):