[cassandra-dtest] branch trunk updated: wait for schema agreements in test_stop_decommission_too_few_replicas_multi_dc

[br...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

brandonwilliams pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-dtest.git


The following commit(s) were added to refs/heads/trunk by this push:
     new ff9068e3 wait for schema agreements in test_stop_decommission_too_few_replicas_multi_dc
ff9068e3 is described below

commit ff9068e30c8cf3882bdf9c69f6e6a0b00a75ac46
Author: Brandon Williams <br...@apache.org>
AuthorDate: Thu Sep 22 14:28:12 2022 -0500

    wait for schema agreements in test_stop_decommission_too_few_replicas_multi_dc
    
    Patch by brandonwilliams; reviewed by edimitrova for CASSANDRA-17894
---
 topology_test.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/topology_test.py b/topology_test.py
index 11485e0f..1f9c6889 100644
--- a/topology_test.py
+++ b/topology_test.py
@@ -476,11 +476,13 @@ class TestTopology(Tester):
         node1, node2, node3, node4 = self.cluster.nodelist()
         session = self.patient_cql_connection(node2)
         session.execute("ALTER KEYSPACE system_distributed WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':'2'};")
+        session.cluster.control_connection.wait_for_schema_agreement()
         create_ks(session, 'ks', {'dc1': 2, 'dc2': 2})
         with pytest.raises(ToolError):
             node4.nodetool('decommission')
 
         session.execute('DROP KEYSPACE ks')
+        session.cluster.control_connection.wait_for_schema_agreement()
         create_ks(session, 'ks2', 4)
         with pytest.raises(ToolError):
             node4.nodetool('decommission')


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org