File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -476,11 +476,13 @@ def test_stop_decommission_too_few_replicas_multi_dc(self):
476476 node1 , node2 , node3 , node4 = self .cluster .nodelist ()
477477 session = self .patient_cql_connection (node2 )
478478 session .execute ("ALTER KEYSPACE system_distributed WITH REPLICATION = {'class':'SimpleStrategy', 'replication_factor':'2'};" )
479+ session .cluster .control_connection .wait_for_schema_agreement ()
479480 create_ks (session , 'ks' , {'dc1' : 2 , 'dc2' : 2 })
480481 with pytest .raises (ToolError ):
481482 node4 .nodetool ('decommission' )
482483
483484 session .execute ('DROP KEYSPACE ks' )
485+ session .cluster .control_connection .wait_for_schema_agreement ()
484486 create_ks (session , 'ks2' , 4 )
485487 with pytest .raises (ToolError ):
486488 node4 .nodetool ('decommission' )
You can’t perform that action at this time.
0 commit comments