From 4455b2a42835e0e9b65acc4f2539baf5b6ed1a75 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 31 Oct 2024 15:51:06 -0700 Subject: [PATCH] rtvi: create queues before tasks --- src/pipecat/processors/frameworks/rtvi.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/pipecat/processors/frameworks/rtvi.py b/src/pipecat/processors/frameworks/rtvi.py index 4ed63b723..af893dcd0 100644 --- a/src/pipecat/processors/frameworks/rtvi.py +++ b/src/pipecat/processors/frameworks/rtvi.py @@ -590,12 +590,12 @@ class RTVIProcessor(FrameProcessor): self._registered_services: Dict[str, RTVIService] = {} # A task to process incoming action frames. - self._action_task = self.get_event_loop().create_task(self._action_task_handler()) self._action_queue = asyncio.Queue() + self._action_task = self.get_event_loop().create_task(self._action_task_handler()) # A task to process incoming transport messages. - self._message_task = self.get_event_loop().create_task(self._message_task_handler()) self._message_queue = asyncio.Queue() + self._message_task = self.get_event_loop().create_task(self._message_task_handler()) self._register_event_handler("on_bot_ready")