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

Update GeminiLiveLLMService to push Thought frames when thought content is returned

Browse Source
This commit is contained in:
Mark Backman
2026-01-13 14:13:00 -05:00
parent d0f227189c
commit 15bc1dd999
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/pipecat/services/google/gemini_live/llm.py
View File

@@ -44,6 +44,9 @@ from pipecat.frames.frames import (
LLMMessagesAppendFrame, LLMMessagesAppendFrame,
LLMSetToolsFrame, LLMSetToolsFrame,
LLMTextFrame, LLMTextFrame,
LLMThoughtEndFrame,
LLMThoughtStartFrame,
LLMThoughtTextFrame,
LLMUpdateSettingsFrame, LLMUpdateSettingsFrame,
StartFrame, StartFrame,
TranscriptionFrame, TranscriptionFrame,
@@ -1455,10 +1458,19 @@ class GeminiLiveLLMService(LLMService):
await self._set_bot_is_responding(True) await self._set_bot_is_responding(True)
await self.push_frame(LLMFullResponseStartFrame()) await self.push_frame(LLMFullResponseStartFrame())
self._bot_text_buffer += text # Check if this is a thought
self._search_result_buffer += text # Also accumulate for grounding if part.thought:
frame = LLMTextFrame(text=text) # Gemini Live emits fully-formed thoughts rather than chunks,
await self.push_frame(frame) # so bracket each thought in start/end frames
await self.push_frame(LLMThoughtStartFrame())
await self.push_frame(LLMThoughtTextFrame(text))
await self.push_frame(LLMThoughtEndFrame(signature=part.thought_signature))
else:
# Regular text response
self._bot_text_buffer += text
self._search_result_buffer += text # Also accumulate for grounding
frame = LLMTextFrame(text=text)
await self.push_frame(frame)
# Check for grounding metadata in server content # Check for grounding metadata in server content
if msg.server_content and msg.server_content.grounding_metadata: if msg.server_content and msg.server_content.grounding_metadata: