We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 55e0c99 commit f458d41Copy full SHA for f458d41
1 file changed
smoketests/tests/replication.py
@@ -490,7 +490,8 @@ def test_enable_disable_replication(self):
490
name = random_string()
491
492
self.publish_module(name, num_replicas = 1)
493
- self.cluster.wait_for_leader_change(None)
+ # ensure database is up and commitlog ends up non-empty
494
+ self.run_counter(1, 100)
495
496
# suspend first
497
self.call_control("suspend_database", {"Name": name})
@@ -500,7 +501,7 @@ def test_enable_disable_replication(self):
500
501
self.call_control("unsuspend_database", {"Name": name})
502
503
self.cluster.wait_for_leader_change(None)
- self.run_counter(1, 100)
504
+ self.run_counter(2, 100)
505
506
self.call_control("disable_replication", {"Name": name})
- self.run_counter(2, 100)
507
+ self.run_counter(3, 100)
0 commit comments