diff --git a/confluent_server/confluent/core.py b/confluent_server/confluent/core.py index 593016a1..b2b90b56 100644 --- a/confluent_server/confluent/core.py +++ b/confluent_server/confluent/core.py @@ -580,6 +580,7 @@ def handle_dispatch(connection, cert, dispatch): if not util.cert_matches( cfm.get_collective_member(dispatch['name'])['fingerprint'], cert): connection.close() + return configmanager = cfm.ConfigManager(dispatch['tenant']) nodes = dispatch['nodes'] inputdata = dispatch['inputdata']