Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions portkey_ai/integrations/adk.py
Original file line number Diff line number Diff line change
Expand Up @@ -242,7 +242,7 @@ def _content_to_input_items(content: Any, system_role: str) -> list[dict[str, An
"id": thought_signature or f"reasoning_{len(items)}",
"type": "reasoning",
"summary": [],
"content": [{"type": "reasoning_text", "text": text}],
"content": [{"type": "reasoning_summary_text", "text": text}],
}
if thought_signature:
reasoning_item["encrypted_content"] = thought_signature
Expand Down Expand Up @@ -435,7 +435,7 @@ def _response_output_to_parts(output: Iterable[Any]) -> list[Any]:
getattr(item, "encrypted_content", None)
)
for content in getattr(item, "content", None) or []:
if getattr(content, "type", None) == "reasoning_text":
if getattr(content, "type", None) == "reasoning_summary_text":
parts.append(
_build_text_part(
getattr(content, "text", ""),
Expand Down Expand Up @@ -652,7 +652,7 @@ async def generate_content_async(
async for event in stream_response: # type: ignore[union-attr] # create() returns union of Response|AsyncStream; we know it's AsyncStream here
event_type: str | None = getattr(event, "type", None)

if event_type == "response.reasoning_text.delta":
if event_type == "response.reasoning_summary_text.delta":
delta: str = getattr(event, "delta", "")
if delta:
yield _parts_to_llm_response(
Expand Down
Loading