From 9e9a6e4e02820dea79e91a3537255b6ad694c1c9 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 9 Apr 2026 11:21:40 +0800 Subject: [PATCH] bugfix --- llmage/asyncinference.py | 6 ++---- llmage/utils.py | 7 +++++++ 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/llmage/asyncinference.py b/llmage/asyncinference.py index ba8c6bd..20c6b7a 100644 --- a/llmage/asyncinference.py +++ b/llmage/asyncinference.py @@ -10,7 +10,6 @@ from appPublic.uniqueID import getID from appPublic.dictObject import DictObject from appPublic.timeUtils import curDateString, timestampstr from appPublic.base64_to_file import base64_to_file, getFilenameFromBase64 -# from uapi.appapi import UAPI, sor_get_callerid, sor_get_uapi from ahserver.serverenv import get_serverenv, ServerEnv from ahserver.filestorage import FileStorage from .accounting import llm_accounting, llm_charging @@ -59,7 +58,6 @@ async def async_uapi_request(request, llm, params_kw = env.params_kw # callerorgid = await env.get_userorgid() # callerid = await env.get_user() - # uapi = UAPI(request, sor=sor) uapi = env.UpAppApi(request) userid = await get_owner_userid(llm) b = None @@ -138,7 +136,7 @@ async def add_new_llmusage_output(luid, newd): r.ioinfo = json.dumps(io, ensure_ascii=False) r.update(newd) await sor.U('llmusage', r) - debug(f'llmuasage update to {r}') + # debug(f'llmuasage update to {r}') return else: exception(f'add_new_llmusage_output({luid}, {newd}) llmusage not found') @@ -174,7 +172,7 @@ async def query_task_status(request, upappid, apiname, luid, userid, taskid): raise e llm = llms[0] lastoutout = get_llmusage_last_output(llmusage) - uapi = UAPI(request, sor) + uapi = UpAppApi(request) apinames = apiname.split(',') for apiname in apinames: status = 'unknown' diff --git a/llmage/utils.py b/llmage/utils.py index 6a5b6e8..fad6bb4 100644 --- a/llmage/utils.py +++ b/llmage/utils.py @@ -13,6 +13,13 @@ from uapi.appapi import UAPI, sor_get_callerid, sor_get_uapi from ahserver.serverenv import get_serverenv, ServerEnv from ahserver.filestorage import FileStorage +async def write_llmio(luid, io_dic): + fs = FileStorage() + s = json.dumps(io_dic, ensure_ascii=False, indent=4) + name = f'{luid}.json' + webpath = await fs.save(name, s, userid='llmio') + return webpath + async def llm_query_orders(userorgid, page, pagerows=80): env = ServerEnv() async with get_sor_context(env, 'llmage') as sor: