kboss/b/computing/cpnode_config_update.dspy
2025-07-16 14:27:17 +08:00

21 lines
744 B
Plaintext

async def cpnode_config_update(ns={}):
ns['quantity'] = len(ns['component_id'])
component_id = json.dumps(ns['component_id']) if isinstance(ns['component_id'], list) else ns['component_id']
ns['component_id'] = component_id
db = DBPools()
async with db.sqlorContext('kboss') as sor:
try:
await sor.U('cpnode_config', ns)
return {
'status': True,
'msg': '算力节点配置信息更新成功'
}
except Exception as e:
return {
'status': False,
'msg': '算力节点配置信息更新错误, %s' % str(e)
}
ret = await cpnode_config_update(params_kw)
return ret