Skipping invalidated metadata test, restrict policy test to C*>2.2

GregBestland · GregBestland · commit 42797209d203 · 2016-09-08T09:52:15.000-05:00
diff --git a/tests/integration/standard/test_policies.py b/tests/integration/standard/test_policies.py
@@ -22,7 +22,7 @@
 from cassandra.cluster import ExecutionProfile
 from cassandra.query import SimpleStatement
 from cassandra.policies import ConstantSpeculativeExecutionPolicy, RoundRobinPolicy
-from tests.integration import BasicSharedKeyspaceUnitTestCase
+from tests.integration import BasicSharedKeyspaceUnitTestCase, greaterthancass21
 
 
 def setup_module():
@@ -52,6 +52,7 @@ def setUp(self):
         self.cluster.add_execution_profile("spec_ep_rr", spec_ep_rr)
         self.cluster.add_execution_profile("spec_ep_rr_lim", spec_ep_rr_lim)
 
+    @greaterthancass21
     def test_speculative_execution(self):
         """
         Test to ensure that speculative execution honors LBP, and that they retry appropriately.
diff --git a/tests/integration/standard/test_prepared_statements.py b/tests/integration/standard/test_prepared_statements.py
@@ -386,6 +386,8 @@ def test_raise_error_on_prepared_statement_execution_dropped_table(self):
         with self.assertRaises(InvalidRequest):
             self.session.execute(prepared, [0])
 
+    # TODO revisit this test
+    @unittest.skip
     def test_invalidated_result_metadata(self):
         """
         Tests to make sure cached metadata is updated when an invalidated prepared statement is reprepared.
@@ -417,6 +419,7 @@ def test_invalidated_result_metadata(self):
         # Get a bunch of requests in the pipeline with varying states of result_meta, reprepare, resolved
         futures = set(s.execute_async(wildcard_prepared.bind(None)) for _ in range(200))
         for f in futures:
+
             self.assertEqual(f.result()[0], (0, 0, 0))
         self.assertIsNot(wildcard_prepared.result_metadata, original_result_metadata)
         s.execute("DROP TABLE %s" % table)
