From 425a730d7c5b50b408e8b0211c87f1167aeec9ce Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 15 Aug 2024 08:33:36 -0700 Subject: [PATCH] transports(base_output): send urgent transport messages immediately --- src/pipecat/transports/base_output.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py index a4169991d..6d619cd41 100644 --- a/src/pipecat/transports/base_output.py +++ b/src/pipecat/transports/base_output.py @@ -151,6 +151,8 @@ class BaseOutputTransport(FrameProcessor): await self._handle_audio(frame) elif isinstance(frame, ImageRawFrame) or isinstance(frame, SpriteFrame): await self._handle_image(frame) + elif isinstance(frame, TransportMessageFrame) and frame.urgent: + await self.send_message(frame) else: await self._sink_queue.put(frame)