bugfix
This commit is contained in:
parent
51eee49c10
commit
b31350b2c1
@ -36,10 +36,10 @@ async def get_asynctask_status(request, taskid):
|
|||||||
if recs:
|
if recs:
|
||||||
r = recs[0]
|
r = recs[0]
|
||||||
output = await get_lastoutput(r.ioinfo)
|
output = await get_lastoutput(r.ioinfo)
|
||||||
t = timestampAdd(r.use_time, 600)
|
t = timestampAdd(r.use_time, 600)
|
||||||
now = time.time()
|
now = time.time()
|
||||||
if r.status not in ['FAILED', 'SUCCEEDED'] and now > t:
|
if r.status not in ['FAILED', 'SUCCEEDED'] and now > t:
|
||||||
asyncio.create_task(query_task_status(request, r.id))
|
asyncio.create_task(query_task_status(request, r.id))
|
||||||
return output
|
return output
|
||||||
return {
|
return {
|
||||||
'taskid': taskid,
|
'taskid': taskid,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user