xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-28 20:07:48 +00:00
Code Issues Projects Releases Wiki Activity

Fix quorum when there is no collective yet

Browse Source
This commit is contained in:
Jarrod Johnson 2023-03-06 16:38:09 -05:00
parent baa365fcac
commit 4d9b11bc55
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
confluent_server/confluent/config/configmanager.py
View File

@ -638,6 +638,10 @@ def has_quorum():
for follower in cfgstreams:
if cfgstreams[follower].get('role', None) != 'nonvoting':
voters += 1
iam = get_collective_member(get_myname())
myrole = None
if iam:
myrole = iam.get('role', None)
myrole = get_collective_member(get_myname()).get('role', None)
if myrole != 'nonvoting':
voters += 1