2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-01-11 18:42:29 +00:00

Background console disconnect on node removal

This commit is contained in:
Jarrod Johnson
2025-04-23 12:33:40 -04:00
parent 690980c064
commit 52b0ae179e

View File

@@ -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):