Skip to content

Fix: 修复 MiniMax API tool_call 参数 JSON 解析失败导致 KeyError #6763

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
alei37 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Fix: 修复 MiniMax API tool_call 参数 JSON 解析失败导致 KeyError #6763

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
49 changes: 35 additions & 14 deletions astrbot/core/provider/sources/anthropic_source.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -418,19 +418,40 @@ async def _query_stream(
if event.index in tool_use_buffer:
# 解析完整的工具调用
tool_info = tool_use_buffer[event.index]
parsed_ok = False

try:
if "input_json" in tool_info:
tool_info["input"] = json.loads(tool_info["input_json"])

# 添加到最终结果
final_tool_calls.append(
{
"id": tool_info["id"],
"name": tool_info["name"],
"input": tool_info["input"],
},
else:
tool_info["input"] = {}
parsed_ok = True

except json.JSONDecodeError as e:
raw_json = tool_info.get("input_json", "")
logger.warning(
f"工具调用参数 JSON 解析失败: {e}。"
f"len={len(raw_json)}; head={raw_json[:120]!r}; tail={raw_json[-120:]!r}"
)

# Fallback：尝试补全可能截断的尾部
for suffix in ["}", "]", '"}', '"]']:
if raw_json and not raw_json.rstrip().endswith(suffix):
try:
tool_info["input"] = json.loads(raw_json + suffix)
parsed_ok = True
logger.info(
f"工具调用参数 JSON 解析成功 (fallback，修复后缀 '{suffix}')"
)
break
except json.JSONDecodeError:
pass

if parsed_ok:
final_tool_calls.append({
"id": tool_info["id"],
"name": tool_info["name"],
"input": tool_info["input"],
})
yield LLMResponse(
role="tool",
completion_text="",
Expand All @@ -441,12 +462,12 @@ async def _query_stream(
usage=usage,
id=id,
)
except json.JSONDecodeError:
# JSON 解析失败，跳过这个工具调用
logger.warning(f"工具调用参数 JSON 解析失败: {tool_info}")
else:
logger.warning(
f"工具调用参数 JSON 解析最终失败，跳过工具调用: {tool_info['name']}"
)

# 清理缓冲区
del tool_use_buffer[event.index]
tool_use_buffer.pop(event.index, None)

elif event.type == "message_delta":
if event.usage:
Expand Down