2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-29 04:17:41 +00:00

Correct scope of currentleader

This commit is contained in:
Jarrod Johnson 2018-05-11 15:03:41 -04:00
parent a2187087f7
commit 9d58a2d382

View File

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