From 5729722dcde17429e2b2c0d8aa969e31dcec38e7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 7 Nov 2025 11:23:31 -0800 Subject: [PATCH] SimliVideoService: check exception initializing simli client --- src/pipecat/services/simli/video.py | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/src/pipecat/services/simli/video.py b/src/pipecat/services/simli/video.py index 383a8a3cb..bac54f35b 100644 --- a/src/pipecat/services/simli/video.py +++ b/src/pipecat/services/simli/video.py @@ -158,14 +158,17 @@ class SimliVideoService(FrameProcessor): async def _start_connection(self): """Start the connection to Simli service and begin processing tasks.""" - if not self._initialized: - await self._simli_client.Initialize() - self._initialized = True + try: + if not self._initialized: + await self._simli_client.Initialize() + self._initialized = True - # Create task to consume and process audio and video - await self._simli_client.sendSilence() - self._audio_task = self.create_task(self._consume_and_process_audio()) - self._video_task = self.create_task(self._consume_and_process_video()) + # Create task to consume and process audio and video + await self._simli_client.sendSilence() + self._audio_task = self.create_task(self._consume_and_process_audio()) + self._video_task = self.create_task(self._consume_and_process_video()) + except Exception as e: + logger.error(f"{self}: unable to start connection: {e}") async def _consume_and_process_audio(self): """Consume audio frames from Simli and push them downstream."""