Skip to content

Commit c43d8fe

Browse files
authored
smoketest: Retry if there is no current leader (#2950)
1 parent bd9ea55 commit c43d8fe

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

smoketests/tests/replication.py

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -102,10 +102,15 @@ def get_leader_info(self):
102102

103103
def wait_for_leader_change(self, previous_leader_node, max_attempts=10, delay=2):
104104
"""Wait for leader to change and return new leader node_id."""
105+
105106
for _ in range(max_attempts):
106-
current_leader = self.get_leader_info()['node_id']
107-
if current_leader != previous_leader_node:
108-
return current_leader
107+
try:
108+
current_leader_node = self.get_leader_info()['node_id']
109+
if current_leader_node != previous_leader_node:
110+
return current_leader_node
111+
except Exception:
112+
print("No current leader")
113+
109114
time.sleep(delay)
110115
return None
111116

0 commit comments

Comments
 (0)