# -*- 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)