diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 6dba9b9c..7337743e 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -575,12 +575,12 @@ def disconnect_node(node, configmanager): def _nodechange(added, deleting, renamed, configmanager): for node in deleting: - disconnect_node(node, configmanager) + eventlet.spawn(disconnect_node, node, configmanager) for node in renamed: disconnect_node(node, configmanager) - connect_node(renamed[node], configmanager) + eventlet.spawn(connect_node, renamed[node], configmanager) for node in added: - connect_node(node, configmanager) + eventlet.spawn(connect_node, node, configmanager) def _start_tenant_sessions(cfm):