database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-05 16:15:50 +03:00
Code Activity

Fix test

Browse Source
This commit is contained in:
Alexander Presnyakov
2025-07-09 01:47:01 +00:00
committed by Serguey Zefirov
parent af6c5bce28
commit f265d6ae18
3 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cmapi/cmapi_server/handlers/cluster.py
View File

@@ -224,14 +224,16 @@ class ClusterHandler():
node, input_config_filename=config, node, input_config_filename=config,
output_config_filename=config output_config_filename=config
) )
with NodeConfig().modify_config(config) as root:
update_dbroots_of_readonly_nodes(root)
except Exception as err: except Exception as err:
raise CMAPIBasicError('Error while removing node.') from err raise CMAPIBasicError('Error while removing node.') from err
response['node_id'] = node response['node_id'] = node
active_nodes = get_active_nodes(config) active_nodes = get_active_nodes(config)
if len(active_nodes) > 0: if len(active_nodes) > 0:
with NodeConfig().modify_config(config) as root:
update_dbroots_of_readonly_nodes(root)
update_revision_and_manager( update_revision_and_manager(
input_config_filename=config, output_config_filename=config input_config_filename=config, output_config_filename=config
) )

4
cmapi/cmapi_server/helpers.py
View File

@@ -135,6 +135,10 @@ def start_transaction(
# this copy will be updated if an optional node can't be reached # this copy will be updated if an optional node can't be reached
real_active_nodes = set(active_nodes) real_active_nodes = set(active_nodes)
logging.trace(f'Active nodes on start transaction {active_nodes}') logging.trace(f'Active nodes on start transaction {active_nodes}')
if not len(active_nodes):
logging.warning('No active nodes found, transaction start will not have any effect')
for node in active_nodes: for node in active_nodes:
url = f'https://{node}:8640/cmapi/{version}/node/begin' url = f'https://{node}:8640/cmapi/{version}/node/begin'
node_success = False node_success = False

1
cmapi/cmapi_server/test/test_node_manip.py
View File

@@ -16,7 +16,6 @@ logging.basicConfig(level='DEBUG')
SINGLE_NODE_XML = "./cmapi_server/SingleNode.xml" SINGLE_NODE_XML = "./cmapi_server/SingleNode.xml"
@unittest.skip('Temp skip for testing reason')
class NodeManipTester(BaseNodeManipTestCase): class NodeManipTester(BaseNodeManipTestCase):
def test_add_remove_node(self): def test_add_remove_node(self):