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 2026-03-30 13:31:03 +08:00
parent 8e4fbe4813
commit 343c652761
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
llmage/asyncinference.py
View File

@ -135,6 +135,13 @@ async def add_new_llmusage_output(luid, newd):
r.update(newd) r.update(newd)
await sor.U('llmusage', r) await sor.U('llmusage', r)
return return
def get_llmusage_last_output(llmusage):
io = json.loads(r.ioinfo)
outs = io.get('output', [])
if len(outs) == 0
return None
d = DictObject(**outs[-1])
return d
async def query_task_status(request, upappid, apiname, luid, userid, taskid): async def query_task_status(request, upappid, apiname, luid, userid, taskid):
env = request._run_ns env = request._run_ns
@ -145,6 +152,9 @@ async def query_task_status(request, upappid, apiname, luid, userid, taskid):
exception(f'{e}') exception(f'{e}')
raise e raise e
llmusage = recs[0] llmusage = recs[0]
lastoutout = get_llmusage_last_output(llmusage)
if lastoutout and lastoutout.status == 'SUCCEEDED':
pass # return
uapi = UAPI(request, sor) uapi = UAPI(request, sor)
apinames = apiname.split(',') apinames = apiname.split(',')
for apiname in apinames: for apiname in apinames: