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/05/13 12:09:04 UTC

[cassandra-dtest] branch trunk updated: wait for schema agreement correctly

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 <br...@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-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org