tenant_id = (await get_userorgid()) or '0'
task_id = params_kw.get('task_id', '')

if not task_id:
    return json.dumps({"success": False, "message": "缺少task_id"}, ensure_ascii=False)

try:
    result = await pipeline_detail(tenant_id, task_id)
    return result
except Exception as e:
    return json.dumps({"success": False, "message": str(e)}, ensure_ascii=False)