File tree Expand file tree Collapse file tree 2 files changed +12
-7
lines changed Expand file tree Collapse file tree 2 files changed +12
-7
lines changed Original file line number Diff line number Diff line change @@ -315,6 +315,15 @@ def get_primary():
315
315
return None
316
316
317
317
318
+ def wait_for_primary ():
319
+ for _ in range (30 ):
320
+ time .sleep (1 )
321
+ if get_primary ():
322
+ break
323
+ else :
324
+ raise AssertionError ("Primary didn't come back up" )
325
+
326
+
318
327
def get_random_secondary ():
319
328
secondaries = get_members_in_state (2 )
320
329
if len (secondaries ):
Original file line number Diff line number Diff line change @@ -703,15 +703,11 @@ def unpartition_node(node):
703
703
704
704
# 3. PRIMARY UP, ONE SECONDARY DOWN -----------------------------------
705
705
ha_tools .restart_members ([killed ])
706
-
707
- for _ in range (30 ):
708
- if ha_tools .get_primary ():
709
- break
710
- sleep (1 )
711
- else :
712
- self .fail ("Primary didn't come back up" )
706
+ ha_tools .wait_for_primary ()
713
707
714
708
ha_tools .kill_members ([unpartition_node (secondary )], 2 )
709
+ sleep (5 )
710
+ ha_tools .wait_for_primary ()
715
711
self .assertTrue (MongoClient (
716
712
unpartition_node (primary ), use_greenlets = use_greenlets ,
717
713
read_preference = PRIMARY_PREFERRED
You can’t perform that action at this time.
0 commit comments