From 2c16faa662b911020a3eae859b344a4af4095cd1 Mon Sep 17 00:00:00 2001 From: Paul Kompfner Date: Fri, 30 Jan 2026 11:15:19 -0500 Subject: [PATCH] WIP Gemini Live Pipecat Flows support --- src/pipecat/services/google/gemini_live/llm.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/pipecat/services/google/gemini_live/llm.py b/src/pipecat/services/google/gemini_live/llm.py index bae6437c4..1e22c1b55 100644 --- a/src/pipecat/services/google/gemini_live/llm.py +++ b/src/pipecat/services/google/gemini_live/llm.py @@ -1033,10 +1033,20 @@ class GeminiLiveLLMService(LLMService): if self._context_update_requires_reconnect(diff): # Reconnect print("[pk] Context update requires reconnect. Reconnecting...") + # TODO: necessary? self._session_resumption_handle = None + # TODO: do something special here to handle the context like it's the initial one again? + + # Reconnect await self._reconnect() + + # Initialize our bookkeeping of already-completed tool calls in + # the context + await self._process_completed_function_calls(send_new_results=False) + + # Trigger "initial" response with new connection await self._create_initial_response() else: # Send results for newly-completed function calls, if any.