From c8cda426be9d0b3a5d9b7996696fb29330e694fe Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 5 Aug 2020 12:57:35 -0400 Subject: [PATCH] Fix crossed wires between user and usergroup The requests were not being routed correctly --- confluent_server/confluent/config/configmanager.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/confluent_server/confluent/config/configmanager.py b/confluent_server/confluent/config/configmanager.py index c642a222..b6be9f1d 100644 --- a/confluent_server/confluent/config/configmanager.py +++ b/confluent_server/confluent/config/configmanager.py @@ -206,11 +206,11 @@ def _rpc_del_usergroup(tenant, name): def _rpc_master_set_usergroup(tenant, name, attributemap): - ConfigManager(tenant).set_user(name, attributemap) + ConfigManager(tenant).set_usergroup(name, attributemap) def _rpc_set_usergroup(tenant, name, attributemap): - ConfigManager(tenant)._true_set_user(name, attributemap) + ConfigManager(tenant)._true_set_usergroup(name, attributemap) def _rpc_master_set_user(tenant, name, attributemap): @@ -652,6 +652,7 @@ def relay_slaved_requests(name, listener): except ValueError as ve: exc = ['ValueError', str(ve)] except Exception as e: + logException() exc = ['Exception', str(e)] if 'xid' in rpc: res = _push_rpc(listener, msgpack.packb({'xid': rpc['xid'],