Merge pull request #4442 from ZeDRoman/issue-3394

ducktape: GroupMetricsTest check if leader exists
redpanda-data · Apr 27, 2022 · dfd73b9 · dfd73b9
2 parents f3ddc0c + d03e9eb
commit dfd73b9
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tests/rptest/tests/group_membership_test.py b/tests/rptest/tests/group_membership_test.py
@@ -326,8 +326,10 @@ def transfer_leadership(new_leader):
                                          partition=0,
                                          target=self.redpanda.idx(new_leader))
             for _ in range(3):  # re-check a few times
-                leader = self.redpanda.get_node(get_group_leader())
-                if leader == new_leader:
+                leader = get_group_leader()
+                self.logger.debug(f"Current leader: {leader}")
+                if leader != -1 and self.redpanda.get_node(
+                        leader) == new_leader:
                     return True
                 time.sleep(1)
             return False