xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-02-15 04:08:59 +00:00
Code Issues Projects Releases Wiki Activity

Fix nodegroup attribute async behavior

Browse Source
This commit is contained in:
Jarrod Johnson
2026-01-22 14:50:59 -05:00
parent 218ecce63f
commit b548002a8d
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
confluent_server/confluent/plugins/configuration/attributes.py
View File

@@ -169,12 +169,12 @@ async def update(nodes, element, configmanager, inputdata):
if nodes is not None:
return await update_nodes(nodes, element, configmanager, inputdata)
elif element[0] == 'nodegroups':
return update_nodegroup(
return await update_nodegroup(
element[1], element[3], configmanager, inputdata)
raise Exception("This line should never be reached")
def update_nodegroup(group, element, configmanager, inputdata):
async def update_nodegroup(group, element, configmanager, inputdata):
if element == 'check':
check = inputdata.attribs
decrypt = configmanager.decrypt
@@ -192,7 +192,7 @@ def update_nodegroup(group, element, configmanager, inputdata):
if 'rename' in element:
namemap = {}
namemap[group] = inputdata.attribs['rename']
configmanager.rename_nodegroups(namemap)
await configmanager.rename_nodegroups(namemap)
return yield_rename_resources(namemap, isnode=False)
try:
clearattribs = []
@@ -208,8 +208,8 @@ def update_nodegroup(group, element, configmanager, inputdata):
for attrib in clearattribs:
del inputdata.attribs[attrib]
if clearattribs:
configmanager.clear_group_attributes(group, clearattribs)
configmanager.set_group_attributes({group: inputdata.attribs})
await configmanager.clear_group_attributes(group, clearattribs)
await configmanager.set_group_attributes({group: inputdata.attribs})
except ValueError as e:
raise exc.InvalidArgumentException(str(e))
return retrieve_nodegroup(group, element, configmanager, inputdata)