From 348867232d267de50b32546684105cb636fd0a5e Mon Sep 17 00:00:00 2001 From: yumoqing Date: Fri, 10 Apr 2026 16:24:47 +0800 Subject: [PATCH] bugfix --- llmage/asyncinference.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/llmage/asyncinference.py b/llmage/asyncinference.py index c1345cb..3416e40 100644 --- a/llmage/asyncinference.py +++ b/llmage/asyncinference.py @@ -5,7 +5,7 @@ from random import randint from functools import partial from traceback import format_exc 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.dictObject import DictObject from appPublic.timeUtils import curDateString, timestampstr @@ -156,6 +156,7 @@ async def query_task_status(request, upappid, apiname, luid, userid, taskid): while True: lastoutout = await get_lastoutput(llmusage.ioinfo) if lastoutout['status'] in ['FAILED', 'SUCCEEDED']: + critical(f"{lastoutout['status']=}") return ns = {'taskid': taskid} 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 modify_llmusage_status(llmusage) if llmusage.status in ['FAILED', 'SUCCEEDED']: - debug(f'finished .. {llmusage.status=}') + dcritical(f'finished .. {llmusage.status=}') return 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=}')