From aa2be98dc3cc76dc090df0de09c7463ec40313fe Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 11 May 2018 15:00:18 -0400 Subject: [PATCH] Fix not having currentleader set A slave node now recognizes itself as such. --- confluent_server/confluent/collective/manager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/confluent_server/confluent/collective/manager.py b/confluent_server/confluent/collective/manager.py index ece48b14..335dae9a 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -79,6 +79,7 @@ def connect_to_leader(cert=None, name=None, leader=None): cfm.set_global(globvar, globaldata[globvar]) cfm.ConfigManager(tenant=None)._load_from_json(dbjson) cfm.ConfigManager._bg_sync_to_file() + currentleader = leader cfm.follow_channel(remote) def get_myname():