From 343c652761d4e30bcf9f023fb884b5b008f1172f Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Mon, 30 Mar 2026 13:31:03 +0800
Subject: [PATCH] bugfix

---
 llmage/asyncinference.py | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/llmage/asyncinference.py b/llmage/asyncinference.py
index 35dde6b..927079e 100644
--- a/llmage/asyncinference.py
+++ b/llmage/asyncinference.py
@@ -135,6 +135,13 @@ async def add_new_llmusage_output(luid, newd):
 			r.update(newd)
 			await sor.U('llmusage', r)
 			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):
 	env = request._run_ns
@@ -145,6 +152,9 @@ async def query_task_status(request, upappid, apiname, luid, userid, taskid):
 			exception(f'{e}')
 			raise e
 		llmusage = recs[0]
+		lastoutout = get_llmusage_last_output(llmusage)
+		if lastoutout and lastoutout.status == 'SUCCEEDED':
+			pass		# return
 		uapi = UAPI(request, sor)
 		apinames = apiname.split(',')
 		for apiname in apinames: