rtvi: internal transport message should be urgent

2024-10-07 08:04:14 -07:00
parent 5dbf26d283
commit 8cdb9ab1ad
1 changed files with 1 additions and 1 deletions
--- a/src/pipecat/processors/frameworks/rtvi.py
+++ b/src/pipecat/processors/frameworks/rtvi.py
@@ -676,7 +676,7 @@ class RTVIProcessor(FrameProcessor):
            self._message_task = None

    async def _push_transport_message(self, model: BaseModel, exclude_none: bool = True):
-        frame = TransportMessageFrame(message=model.model_dump(exclude_none=exclude_none))
+        frame = TransportMessageUrgentFrame(message=model.model_dump(exclude_none=exclude_none))
        await self.push_frame(frame)

    async def _action_task_handler(self):