adiuvAI/api
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Fix using tools in home agent

Browse Source
This commit is contained in:
Roberto
2026-04-19 14:48:05 +02:00
parent ea9094f47f
commit 2c7cac9e03
2 changed files with 14 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
app/core/deep_agent.py
View File

@@ -858,25 +858,15 @@ async def _run_single_agent_stream(
_gen.update(output=_as_text(response.content), usage_details=extract_usage(response))
_gen_ctx.__exit__(None, None, None)
messages.append(response)
if not response.tool_calls:
emitted_any = False
async for chunk in llm.astream(messages):
token = _as_text(getattr(chunk, "content", ""))
if token:
streamed_chars += len(token)
streamed_text.append(token)
emitted_any = True
yield "token", token
# Some providers return final text in `response.content` but stream no chunks.
if not emitted_any:
fallback_text = _as_text(response.content)
if fallback_text:
streamed_chars += len(fallback_text)
streamed_text.append(fallback_text)
yield "token", fallback_text
# Yield the content from the ainvoke response directly — no second LLM call.
# Previously, messages.append(response) was called first, so the re-stream
# received [System, Human, AI] and regenerated a response without tools bound.
final_text = _as_text(response.content)
if final_text:
streamed_chars += len(final_text)
streamed_text.append(final_text)
yield "token", final_text
logger.info(
"deep_agent: run_single_agent_stream_end trace=%s user=%s tool_calls=%d response_chars=%d",
trace_id or "-",
@@ -888,6 +878,7 @@ async def _run_single_agent_stream(
_span.update(output="".join(streamed_text))
return
messages.append(response)
tool_map = {tool_def.name: tool_def for tool_def in tools}
for call in response.tool_calls:
tool_calls_count += 1