修复模型回复没有发送问题
This commit is contained in:
@@ -190,6 +190,7 @@ async def chat_stream(request: ChatRequest):
|
|||||||
subgraphs=True
|
subgraphs=True
|
||||||
# 不再需要,行為已包含
|
# 不再需要,行為已包含
|
||||||
):
|
):
|
||||||
|
logger.info(event)
|
||||||
# 取得 checkpoint_id(可選,視前端是否真的需要)
|
# 取得 checkpoint_id(可選,視前端是否真的需要)
|
||||||
latest_state = await app.aget_state(current_config)
|
latest_state = await app.aget_state(current_config)
|
||||||
configurable = latest_state.config.get("configurable", {})
|
configurable = latest_state.config.get("configurable", {})
|
||||||
@@ -228,7 +229,7 @@ async def chat_stream(request: ChatRequest):
|
|||||||
}
|
}
|
||||||
|
|
||||||
if isinstance(message, AIMessageChunk):
|
if isinstance(message, AIMessageChunk):
|
||||||
if message.tool_call_chunks:
|
if node_name != 'Researcher' and not message.tool_call_chunks:
|
||||||
payload_out.update({
|
payload_out.update({
|
||||||
"type": "delta",
|
"type": "delta",
|
||||||
"is_delta": True,
|
"is_delta": True,
|
||||||
|
|||||||
Reference in New Issue
Block a user