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 918c0a60 wait for schema agreement correctly 918c0a60 is described below commit 918c0a60382d5c8028a43452c6070683e205450e Author: Brandon Williams <brandonwilli...@apache.org> AuthorDate: Thu May 12 14:50:41 2022 -0500 wait for schema agreement correctly Patch by brandonwilliams; reviewed by bereng and edimitrova for CASSANDRA-17606 --- upgrade_tests/upgrade_through_versions_test.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/upgrade_tests/upgrade_through_versions_test.py b/upgrade_tests/upgrade_through_versions_test.py index 392e5f13..dcff3fc5 100644 --- a/upgrade_tests/upgrade_through_versions_test.py +++ b/upgrade_tests/upgrade_through_versions_test.py @@ -385,7 +385,6 @@ class TestUpgrade(Tester): self._create_schema() else: logger.debug("Skipping schema creation (should already be built)") - time.sleep(5) # sigh... self._log_current_ver(self.test_version_metas[0]) @@ -546,6 +545,7 @@ class TestUpgrade(Tester): c counter, PRIMARY KEY (k1) );""") + session.cluster.control_connection.wait_for_schema_agreement() def _create_schema(self): session = self.patient_cql_connection(self.node2, protocol_version=self.protocol_version) @@ -563,6 +563,7 @@ class TestUpgrade(Tester): c counter, PRIMARY KEY (k1, k2) );""") + session.cluster.control_connection.wait_for_schema_agreement() def _write_values(self, num=100): session = self.patient_cql_connection(self.node2, protocol_version=self.protocol_version) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org