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-11-13 16:47:31 +08:00
parent 4c82deb0a4
commit f3f532715d
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

@ -182,7 +182,7 @@ async def uapi_request(request, llm, sor, params_kw=None):
s = json.dumps(ed) s = json.dumps(ed)
s = ''.join(s.split('\n')) s = ''.join(s.split('\n'))
outlines.append(ed) outlines.append(ed)
yield f'{s}\n') yield f'{s}\n'
await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor) await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor)
return return
@ -212,7 +212,7 @@ async def sync_uapi_request(request, llm, sor, params_kw=None):
s = json.dumps(ed) s = json.dumps(ed)
s = ''.join(s.split('\n')) s = ''.join(s.split('\n'))
outlines.append(ed) outlines.append(ed)
yield f'{s}\n') yield f'{s}\n'
await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor) await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor)
return return
d['llmusageid'] = luid d['llmusageid'] = luid
@ -246,7 +246,7 @@ async def async_uapi_request(request, llm, sor, params_kw=None):
s = json.dumps(ed) s = json.dumps(ed)
s = ''.join(s.split('\n')) s = ''.join(s.split('\n'))
outlines.append(ed) outlines.append(ed)
yield f'{s}\n') yield f'{s}\n'
await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor) await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor)
return return
if isinstance(b, bytes): if isinstance(b, bytes):
@ -269,7 +269,7 @@ async def async_uapi_request(request, llm, sor, params_kw=None):
s = json.dumps(ed) s = json.dumps(ed)
s = ''.join(s.split('\n')) s = ''.join(s.split('\n'))
outlines.append(ed) outlines.append(ed)
yield f'{s}\n') yield f'{s}\n'
await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor) await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor)
return return
@ -288,7 +288,7 @@ async def async_uapi_request(request, llm, sor, params_kw=None):
s = json.dumps(ed) s = json.dumps(ed)
s = ''.join(s.split('\n')) s = ''.join(s.split('\n'))
outlines.append(ed) outlines.append(ed)
yield f'{s}\n') yield f'{s}\n'
await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor) await write_llmusage(luid, llm, callerid, None, params_kw, outlines, sor)
return return
if rzt.status == 'SUCCEEDED': if rzt.status == 'SUCCEEDED':