Merge branch 'main' into groundingMetadata

2025-06-24 22:00:16 -04:00
parent e3fe040017 8f7ed12262
commit 1cf0b35ac1
63 changed files with 4150 additions and 249 deletions
--- a/src/pipecat/services/gemini_multimodal_live/gemini.py
+++ b/src/pipecat/services/gemini_multimodal_live/gemini.py
@@ -736,6 +736,8 @@ class GeminiMultimodalLiveLLMService(LLMService):

    async def _receive_task_handler(self):
        async for message in self._websocket:
+            self.start_watchdog()
+
            evt = events.parse_server_event(message)
            # logger.debug(f"Received event: {message[:500]}")
            # logger.debug(f"Received event: {evt}")
@@ -764,6 +766,9 @@ class GeminiMultimodalLiveLLMService(LLMService):
                logger.warning(f"Received unhandled server event type: {evt}")
                pass

+
+            self.reset_watchdog()
+
    #
    #
    #