yumoqing
34a13ebf37
- 证据: pipeline_steps、pipeline_versions 表恒为0行, 三功能上线后从未使用 - 产线定义已收敛为代码能力包(PipelineAbility)+pipelines表元数据, 页面无法定义新能力(每种能力需先写代码注册handler), 在线开发属伪命题 - 删除: wwwroot 下 pipelines/pipeline_steps/pipeline_versions/pipeline_editor 页面目录与配套 API dspy、json/models CRUD 定义、init.py 死函数、 load_path.py 权限注册 - 保留: pipelines 表(agent 运行时读 name/default_model)、executor 引擎、 agent/llm/skill_proposals 等模块主体
80 lines
2.5 KiB
Python
80 lines
2.5 KiB
Python
"""pipeline_core 模块 - 产线平台核心模块
|
||
|
||
产线定义已收敛为代码能力包（PipelineAbility，见 ability.py）+ pipelines 表元数据
|
||
（id/name/default_model，agent 运行时读取）。原「产线管理」在线定义/步骤/发布三功能
|
||
已移除（2026-08-28，能力无法通过页面定义，属死库存）。
|
||
"""
|
||
import json
|
||
from appPublic.uniqueID import getID
|
||
from sqlor.dbpools import DBPools
|
||
from ahserver.serverenv import ServerEnv
|
||
from appPublic.log import debug
|
||
|
||
|
||
MODULE_NAME = 'pipeline_core'
|
||
DBNAME = 'pipeline'
|
||
|
||
|
||
def _get_sor():
|
||
"""Get database pool and dbname for pipeline_core module."""
|
||
return DBPools(), DBNAME
|
||
|
||
|
||
async def create_llm(params_kw):
|
||
result = {'success': False, 'message': ''}
|
||
try:
|
||
db, dbname = _get_sor()
|
||
async with db.sqlorContext(dbname) as sor:
|
||
data = params_kw.copy()
|
||
data.pop('page', None)
|
||
data.pop('rows', None)
|
||
data.pop('data_filter', None)
|
||
data['id'] = getID()
|
||
await sor.C('llm', data)
|
||
result['success'] = True
|
||
result['message'] = '创建成功'
|
||
except Exception as e:
|
||
result['message'] = str(e)
|
||
return json.dumps(result, ensure_ascii=False, default=str)
|
||
|
||
|
||
async def update_llm(params_kw):
|
||
result = {'success': False, 'message': ''}
|
||
try:
|
||
db, dbname = _get_sor()
|
||
async with db.sqlorContext(dbname) as sor:
|
||
data = params_kw.copy()
|
||
data.pop('page', None)
|
||
data.pop('rows', None)
|
||
data.pop('data_filter', None)
|
||
await sor.U('llm', data)
|
||
result['success'] = True
|
||
result['message'] = '更新成功'
|
||
except Exception as e:
|
||
result['message'] = str(e)
|
||
return json.dumps(result, ensure_ascii=False, default=str)
|
||
|
||
|
||
async def delete_llm(params_kw):
|
||
result = {'success': False, 'message': ''}
|
||
try:
|
||
db, dbname = _get_sor()
|
||
async with db.sqlorContext(dbname) as sor:
|
||
await sor.D('llm', {'id': params_kw.get('id')})
|
||
result['success'] = True
|
||
result['message'] = '删除成功'
|
||
except Exception as e:
|
||
result['message'] = str(e)
|
||
return json.dumps(result, ensure_ascii=False, default=str)
|
||
|
||
|
||
def load_pipeline_core():
|
||
"""注册函数到 ServerEnv"""
|
||
env = ServerEnv()
|
||
# LLM
|
||
env.create_llm = create_llm
|
||
env.update_llm = update_llm
|
||
env.delete_llm = delete_llm
|
||
debug(f'[{MODULE_NAME}] module loaded')
|
||
return True
|