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-04-10 16:24:47 +08:00
parent 5e4ddac663
commit 348867232d
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
llmage/asyncinference.py
View File

@ -5,7 +5,7 @@ from random import randint
from functools import partial from functools import partial
from traceback import format_exc from traceback import format_exc
from sqlor.dbpools import DBPools, get_sor_context from sqlor.dbpools import DBPools, get_sor_context
from appPublic.log import debug, exception, error from appPublic.log import debug, exception, error, critical
from appPublic.uniqueID import getID from appPublic.uniqueID import getID
from appPublic.dictObject import DictObject from appPublic.dictObject import DictObject
from appPublic.timeUtils import curDateString, timestampstr from appPublic.timeUtils import curDateString, timestampstr
@ -156,6 +156,7 @@ async def query_task_status(request, upappid, apiname, luid, userid, taskid):
while True: while True:
lastoutout = await get_lastoutput(llmusage.ioinfo) lastoutout = await get_lastoutput(llmusage.ioinfo)
if lastoutout['status'] in ['FAILED', 'SUCCEEDED']: if lastoutout['status'] in ['FAILED', 'SUCCEEDED']:
critical(f"{lastoutout['status']=}")
return return
ns = {'taskid': taskid} ns = {'taskid': taskid}
new_output = b = d = None new_output = b = d = None
@ -175,9 +176,9 @@ async def query_task_status(request, upappid, apiname, luid, userid, taskid):
await append_new_llmoutput(llmusage.id, new_output) await append_new_llmoutput(llmusage.id, new_output)
await modify_llmusage_status(llmusage) await modify_llmusage_status(llmusage)
if llmusage.status in ['FAILED', 'SUCCEEDED']: if llmusage.status in ['FAILED', 'SUCCEEDED']:
debug(f'finished .. {llmusage.status=}') dcritical(f'finished .. {llmusage.status=}')
return return
await asyncio.sleep(llm.query_period or 30) await asyncio.sleep(llm.query_period or 30)
debug(f'{llm.query_period=} seconds will retry, {changed.status=}') critical(f'{llm.query_period=} seconds will retry, {changed.status=}')