From 297513bba7c06e689c70b392bfd07ad256c7cd90 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 11 May 2018 15:03:41 -0400 Subject: [PATCH] Correct scope of currentleader --- 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 335dae9a..002eb94b 100644 --- a/confluent_server/confluent/collective/manager.py +++ b/confluent_server/confluent/collective/manager.py @@ -33,6 +33,7 @@ currentleader = None def connect_to_leader(cert=None, name=None, leader=None): + global currentleader if leader is None: leader = currentleader remote = socket.create_connection((leader, 13001))