18 lines
471 B
Plaintext
18 lines
471 B
Plaintext
# -*- coding:utf-8 -*-
|
|
# GET /api/task?task_id=xxx - 查询任务状态
|
|
|
|
import json
|
|
from ahserver.serverenv import ServerEnv
|
|
|
|
task_id = params_kw.get('task_id', '')
|
|
if not task_id:
|
|
return json.dumps({'error': 'task_id is required'}, ensure_ascii=False)
|
|
|
|
env = ServerEnv()
|
|
longtasks = env.longtasks
|
|
if longtasks is None:
|
|
return json.dumps({'error': 'service not ready'}, ensure_ascii=False)
|
|
|
|
status = await longtasks.get_status(task_id)
|
|
return json.dumps(status)
|