Skip to content

Commit f6a0686

Browse files
committed
Fix TestHealthMonitor.test_primary_stepdown.
1 parent 8054e95 commit f6a0686

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

test/high_availability/test_ha.py

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -400,12 +400,13 @@ def test_primary_stepdown(self):
400400
sleep(1)
401401
rs_state = c._MongoReplicaSetClient__rs_state
402402
if rs_state.writer and rs_state.writer != primary:
403-
# New primary stepped up
404-
new_primary = _partition_node(ha_tools.get_primary())
405-
self.assertEqual(new_primary, rs_state.writer)
406-
new_secondaries = partition_nodes(ha_tools.get_secondaries())
407-
self.assertEqual(set(new_secondaries), rs_state.secondaries)
408-
break
403+
if ha_tools.get_primary():
404+
# New primary stepped up
405+
new_primary = _partition_node(ha_tools.get_primary())
406+
self.assertEqual(new_primary, rs_state.writer)
407+
new_secondaries = partition_nodes(ha_tools.get_secondaries())
408+
self.assertEqual(set(new_secondaries), rs_state.secondaries)
409+
break
409410
else:
410411
self.fail(
411412
"No new primary after %s seconds. Old primary was %s, current"

0 commit comments

Comments
 (0)