yumoqing/llmage
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2025-10-13 12:32:46 +08:00
parent 5ddbd704ba
commit 39094dae26
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
llmage/llmclient.py
View File

@ -119,7 +119,7 @@ async def uapi_request(request, llm, sor):
yield json.dumps(d) + '\n' yield json.dumps(d) + '\n'
except Exception as e: except Exception as e:
exception(f'{e=},{format_exc()}') exception(f'{e=},{format_exc()}')
yield f'{{"error": f"ERROR:{e=}"}}\n' yield f'{{"error": "ERROR:{e=}"}}\n'
return return
debug(f'{txt=}') debug(f'{txt=}')
@ -135,7 +135,7 @@ async def sync_uapi_request(request, llm, sor):
b = await uapi.call(llm.upappid, llm.apiname, userid, params=env.params_kw) b = await uapi.call(llm.upappid, llm.apiname, userid, params=env.params_kw)
except Exception as e: except Exception as e:
exception(f'{e=},{format_exc()}') exception(f'{e=},{format_exc()}')
yield f'{{"error": f"ERROR:{e=}"}}\n' yield f'{{"error": "ERROR:{e=}"}}\n'
return return
if isinstance(b, bytes): if isinstance(b, bytes):
b = b.decode('utf-8') b = b.decode('utf-8')
@ -153,7 +153,7 @@ async def async_uapi_request(request, llm, sor):
b = await uapi.call(llm.upappid, llm.apiname, userid, params=env.params_kw) b = await uapi.call(llm.upappid, llm.apiname, userid, params=env.params_kw)
except Exception as e: except Exception as e:
exception(f'{e=},{format_exc()}') exception(f'{e=},{format_exc()}')
yield f'{{"error": f"ERROR:{e=}"}}\n' yield f'{{"error": "ERROR:{e=}"}}\n'
return return
if isinstance(b, bytes): if isinstance(b, bytes):
b = b.decode('utf-8') b = b.decode('utf-8')
@ -172,7 +172,7 @@ async def async_uapi_request(request, llm, sor):
b = await uapi.call(llm.upappid, apiname, userid, params=d.context) b = await uapi.call(llm.upappid, apiname, userid, params=d.context)
except Exception as e: except Exception as e:
exception(f'{e=},{format_exc()}') exception(f'{e=},{format_exc()}')
yield f'{{"error": f"ERROR:{e=}"}}\n' yield f'{{"error": "ERROR:{e=}"}}\n'
break break
if isinstance(b, bytes): if isinstance(b, bytes):
@ -183,7 +183,7 @@ async def async_uapi_request(request, llm, sor):
yield b + '\n' yield b + '\n'
if not rzt.status or rzt.status == 'FAILED': if not rzt.status or rzt.status == 'FAILED':
debug(f'{b=} return error') debug(f'{b=} return error')
yield f'{{"error": f"ERROR:{e=}"}}\n' yield f'{{"error": "ERROR:{e=}"}}\n'
return return
if rzt.status == 'SUCCEEDED': if rzt.status == 'SUCCEEDED':
debug(f'{b=} return successed') debug(f'{b=} return successed')