You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2022/10/17 11:21:28 UTC
[cassandra-dtest] branch trunk updated: Wait for schema and binary
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 f7f7bc4b Wait for schema and binary
f7f7bc4b is described below
commit f7f7bc4b54b12ed2243fa0b095e407afd9ad8bde
Author: Brandon Williams <br...@apache.org>
AuthorDate: Wed Oct 12 17:06:26 2022 -0500
Wait for schema and binary
Patch by brandonwilliams; reviewed by bereng for CASSANDRA-17634
---
upgrade_tests/drop_compact_storage_upgrade_test.py | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/upgrade_tests/drop_compact_storage_upgrade_test.py b/upgrade_tests/drop_compact_storage_upgrade_test.py
index 45cbeed0..b7a7f9ce 100644
--- a/upgrade_tests/drop_compact_storage_upgrade_test.py
+++ b/upgrade_tests/drop_compact_storage_upgrade_test.py
@@ -30,8 +30,10 @@ class TestDropCompactStorage(Tester):
session = self.patient_exclusive_cql_connection(node1)
session.execute(
"CREATE KEYSPACE drop_compact_storage_test WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '2'};")
+ session.cluster.control_connection.wait_for_schema_agreement()
session.execute(
"CREATE TABLE drop_compact_storage_test.test (a text PRIMARY KEY, b text, c text) WITH COMPACT STORAGE;")
+ session.cluster.control_connection.wait_for_schema_agreement()
for i in range(1, 100):
session.execute(
@@ -54,7 +56,7 @@ class TestDropCompactStorage(Tester):
node.set_install_dir(version=to_version)
node.set_configuration_options(values={'enable_drop_compact_storage': 'true'})
- node.start(wait_other_notice=False, wait_for_binary_proto=False, verbose=False)
+ node.start(wait_for_binary_proto=True)
@since('3.0', max_version='3.11')
def test_drop_compact_storage(self):
@@ -94,6 +96,7 @@ class TestDropCompactStorage(Tester):
time.sleep(2)
session.execute("ALTER TABLE drop_compact_storage_test.test DROP COMPACT STORAGE")
+ session.cluster.control_connection.wait_for_schema_agreement()
session.execute("SELECT * FROM drop_compact_storage_test.test")
@since('4.0')
@@ -162,4 +165,5 @@ class TestDropCompactStorage(Tester):
session = self.patient_exclusive_cql_connection(node1)
session.execute("SELECT * FROM drop_compact_storage_test.test")
session.execute("ALTER TABLE drop_compact_storage_test.test DROP COMPACT STORAGE")
+ session.cluster.control_connection.wait_for_schema_agreement()
session.execute("SELECT * FROM drop_compact_storage_test.test")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org