xinyin025/LangBot
1
0
Fork 0
mirror of https://github.com/langbot-app/LangBot.git synced 2026-08-13 14:10:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

weknora2

Browse Source
This commit is contained in:
Typer_Body
2026-06-07 01:14:02 +08:00
parent 59f20bcc73
commit af451e7006
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/langbot/libs/weknora_api/v1/client.py
+10 -2
View File
@@ -114,9 +114,13 @@ class AsyncWeKnoraClient:
continue continue
if chunk.startswith('data:'): if chunk.startswith('data:'):
try: try:
yield json.loads(chunk[5:].strip()) data = json.loads(chunk[5:].strip())
except json.JSONDecodeError: except json.JSONDecodeError:
continue continue
yield data
# 收到 error 事件后主动结束流，避免上层未 raise 时持续等待
if data.get('response_type') == 'error':
return
async def knowledge_chat( async def knowledge_chat(
self, self,
@@ -167,6 +171,10 @@ class AsyncWeKnoraClient:
continue continue
if chunk.startswith('data:'): if chunk.startswith('data:'):
try: try:
yield json.loads(chunk[5:].strip()) data = json.loads(chunk[5:].strip())
except json.JSONDecodeError: except json.JSONDecodeError:
continue continue
yield data
# 收到 error 事件后主动结束流，避免上层未 raise 时持续等待
if data.get('response_type') == 'error':
return