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

rtvi: delay creating tasks until we get StartFrame

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-01-31 10:06:11 -08:00
parent d95819746a
commit 002699f16c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/pipecat/processors/frameworks/rtvi.py
View File

@@ -764,11 +764,11 @@ class RTVIProcessor(FrameProcessor):
# A task to process incoming action frames. # A task to process incoming action frames.
self._action_queue = asyncio.Queue() 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. # A task to process incoming transport messages.
self._message_queue = asyncio.Queue() 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_bot_started")
self._register_event_handler("on_client_ready") self._register_event_handler("on_client_ready")
@@ -863,6 +863,8 @@ class RTVIProcessor(FrameProcessor):
await self._pipeline.cleanup() await self._pipeline.cleanup()
async def _start(self, frame: StartFrame): 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") await self._call_event_handler("on_bot_started")
async def _stop(self, frame: EndFrame): async def _stop(self, frame: EndFrame):