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