fix: asyncinference KeyError status→.get(status)
This commit is contained in:
parent
c099af6bc7
commit
e246f91e77
@ -177,8 +177,8 @@ async def query_task_status(request, luid, onetime=False):
|
|||||||
for apiname in apinames:
|
for apiname in apinames:
|
||||||
while True:
|
while True:
|
||||||
lastoutout = await get_lastoutput(llmusage.ioinfo)
|
lastoutout = await get_lastoutput(llmusage.ioinfo)
|
||||||
if lastoutout['status'] in ['UNKNOWN', 'FAILED', 'SUCCEEDED']:
|
if lastoutout.get('status', '') in ['UNKNOWN', 'FAILED', 'SUCCEEDED']:
|
||||||
critical(f"{lastoutout['status']=}")
|
critical(f"{lastoutout.get('status', '')=}")
|
||||||
return
|
return
|
||||||
ns = {'taskid': taskid}
|
ns = {'taskid': taskid}
|
||||||
new_output = b = d = None
|
new_output = b = d = None
|
||||||
@ -197,7 +197,7 @@ async def query_task_status(request, luid, onetime=False):
|
|||||||
e = Exception(f"{new_output=} {upappid=}, {apiname=} has not status field")
|
e = Exception(f"{new_output=} {upappid=}, {apiname=} has not status field")
|
||||||
critical(f'{e}')
|
critical(f'{e}')
|
||||||
raise e
|
raise e
|
||||||
if lastoutout['status'] != new_output.get('status'):
|
if lastoutout.get('status', '') != new_output.get('status'):
|
||||||
llmusage.status = new_output['status']
|
llmusage.status = new_output['status']
|
||||||
ns = {
|
ns = {
|
||||||
'id': llmusage.id,
|
'id': llmusage.id,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user