- 纯薄交互层,无数据表,调用 pipeline-service 引擎函数 - 6个dspy API(submit/list/detail/node/modify/control) - 4个UI页面(index/list/detail/submit) - pipeline_task.js 交互辅助函数 - load_path.py RBAC 权限注册 - 完整 README 文档
14 lines
503 B
Plaintext
14 lines
503 B
Plaintext
tenant_id = (await get_userorgid()) or '0'
|
|
task_id = params_kw.get('task_id', '')
|
|
step_name = params_kw.get('step_name', '')
|
|
version = params_kw.get('version', None)
|
|
|
|
if not task_id or not step_name:
|
|
return json.dumps({"success": False, "message": "缺少task_id或step_name"}, ensure_ascii=False)
|
|
|
|
try:
|
|
result = await pipeline_node(tenant_id, task_id, step_name, version)
|
|
return result
|
|
except Exception as e:
|
|
return json.dumps({"success": False, "message": str(e)}, ensure_ascii=False)
|