user_id = await get_user()
if not user_id:
    return json.dumps({"status": "error", "message": "未登录"}, ensure_ascii=False)

pipeline_id = params_kw.get('pipeline_id', '')
step = params_kw.get('step', '')
version = params_kw.get('version', None)

if not pipeline_id or not step:
    return json.dumps({"status": "error", "message": "缺少pipeline_id或step"}, ensure_ascii=False)

try:
    result = await hermes_pipeline_node(pipeline_id, step, version)
    return json.dumps(result, ensure_ascii=False)
except Exception as e:
    return json.dumps({"status": "error", "message": str(e)}, ensure_ascii=False)