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