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:
parent
aa2be98dc3
commit
297513bba7
@ -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))
|
||||
|
Loading…
x
Reference in New Issue
Block a user