mirror/nanobot
1
0
Fork 0
mirror of https://github.com/HKUDS/nanobot.git synced 2026-04-27 05:15:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(provider): extend StepFun reasoning fallback to all code paths

Browse Source 
- Add reasoning_content fallback from reasoning in _parse dict branch
- Add content fallback from msg.reasoning in _parse SDK object branch
- Add reasoning_content fallback in _parse SDK object branch
- Add reasoning fallback in _parse_chunks dict branch
- Add reasoning fallback in _parse_chunks SDK object branch

This ensures StepFun Plan API works correctly in both streaming and
non-streaming modes, for both dict and SDK object response formats.
This commit is contained in:
moranfong 2026-04-07 23:38:04 +08:00 committed by Xubin Ren
parent 9e7c07ac89
commit 12ff8b22d6
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
nanobot/providers/openai_compat_provider.py
View File

@ -459,6 +459,8 @@ class OpenAICompatProvider(LLMProvider):
if not content and msg0.get("reasoning"): if not content and msg0.get("reasoning"):
content = self._extract_text_content(msg0.get("reasoning")) content = self._extract_text_content(msg0.get("reasoning"))
reasoning_content = msg0.get("reasoning_content") reasoning_content = msg0.get("reasoning_content")
if not reasoning_content and msg0.get("reasoning"):
reasoning_content = self._extract_text_content(msg0.get("reasoning"))
for ch in choices: for ch in choices:
ch_map = self._maybe_mapping(ch) or {} ch_map = self._maybe_mapping(ch) or {}
m = self._maybe_mapping(ch_map.get("message")) or {} m = self._maybe_mapping(ch_map.get("message")) or {}
@ -514,6 +516,8 @@ class OpenAICompatProvider(LLMProvider):
finish_reason = ch.finish_reason finish_reason = ch.finish_reason
if not content and m.content: if not content and m.content:
content = m.content content = m.content
if not content and getattr(m, "reasoning", None):
content = m.reasoning
tool_calls = [] tool_calls = []
for tc in raw_tool_calls: for tc in raw_tool_calls:
@ -530,12 +534,16 @@ class OpenAICompatProvider(LLMProvider):
function_provider_specific_fields=fn_prov, function_provider_specific_fields=fn_prov,
)) ))
reasoning_content = getattr(msg, "reasoning_content", None) or None
if not reasoning_content and getattr(msg, "reasoning", None):
reasoning_content = msg.reasoning
return LLMResponse( return LLMResponse(
content=content, content=content,
tool_calls=tool_calls, tool_calls=tool_calls,
finish_reason=finish_reason or "stop", finish_reason=finish_reason or "stop",
usage=self._extract_usage(response), usage=self._extract_usage(response),
reasoning_content=getattr(msg, "reasoning_content", None) or None, reasoning_content=reasoning_content,
) )
@classmethod @classmethod
@ -596,6 +604,8 @@ class OpenAICompatProvider(LLMProvider):
if text: if text:
content_parts.append(text) content_parts.append(text)
text = cls._extract_text_content(delta.get("reasoning_content")) text = cls._extract_text_content(delta.get("reasoning_content"))
if not text:
text = cls._extract_text_content(delta.get("reasoning"))
if text: if text:
reasoning_parts.append(text) reasoning_parts.append(text)
for idx, tc in enumerate(delta.get("tool_calls") or []): for idx, tc in enumerate(delta.get("tool_calls") or []):
@ -614,6 +624,8 @@ class OpenAICompatProvider(LLMProvider):
content_parts.append(delta.content) content_parts.append(delta.content)
if delta: if delta:
reasoning = getattr(delta, "reasoning_content", None) reasoning = getattr(delta, "reasoning_content", None)
if not reasoning:
reasoning = getattr(delta, "reasoning", None)
if reasoning: if reasoning:
reasoning_parts.append(reasoning) reasoning_parts.append(reasoning)
for tc in (delta.tool_calls or []) if delta else []: for tc in (delta.tool_calls or []) if delta else []: