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

transports(services): incoming transport messages should be urgent

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-12-03 10:48:50 -08:00
parent 52cefaa9d6
commit a6a4910931
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/services/daily.py
View File

@@ -723,7 +723,7 @@ class DailyInputTransport(BaseInputTransport):
await self.push_frame(frame) await self.push_frame(frame)
async def push_app_message(self, message: Any, sender: str): 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) await self.push_frame(frame)
# #

2
src/pipecat/transports/services/livekit.py
View File

@@ -342,7 +342,7 @@ class LiveKitInputTransport(BaseInputTransport):
return self._vad_analyzer return self._vad_analyzer
async def push_app_message(self, message: Any, sender: str): 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) await self.push_frame(frame)
async def _audio_in_task_handler(self): async def _audio_in_task_handler(self):