From 002699f16cbf0872a524fb188a174f025fd8ba6c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 31 Jan 2025 10:06:11 -0800 Subject: [PATCH] rtvi: delay creating tasks until we get StartFrame --- src/pipecat/processors/frameworks/rtvi.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/pipecat/processors/frameworks/rtvi.py b/src/pipecat/processors/frameworks/rtvi.py index f59b6d48f..90495f8c7 100644 --- a/src/pipecat/processors/frameworks/rtvi.py +++ b/src/pipecat/processors/frameworks/rtvi.py @@ -764,11 +764,11 @@ class RTVIProcessor(FrameProcessor): # A task to process incoming action frames. self._action_queue = asyncio.Queue() - self._action_task = self.create_task(self._action_task_handler()) + self._action_task: Optional[asyncio.Task] = None # A task to process incoming transport messages. self._message_queue = asyncio.Queue() - self._message_task = self.create_task(self._message_task_handler()) + self._message_task: Optional[asyncio.Task] = None self._register_event_handler("on_bot_started") self._register_event_handler("on_client_ready") @@ -863,6 +863,8 @@ class RTVIProcessor(FrameProcessor): await self._pipeline.cleanup() async def _start(self, frame: StartFrame): + self._action_task = self.create_task(self._action_task_handler()) + self._message_task = self.create_task(self._message_task_handler()) await self._call_event_handler("on_bot_started") async def _stop(self, frame: EndFrame):