diff --git a/tests/integration/long/test_loadbalancingpolicies.py b/tests/integration/long/test_loadbalancingpolicies.py index 40f08939..98663928 100644 --- a/tests/integration/long/test_loadbalancingpolicies.py +++ b/tests/integration/long/test_loadbalancingpolicies.py @@ -16,7 +16,7 @@ import struct, time, logging, sys, traceback from cassandra import ConsistencyLevel, Unavailable, OperationTimedOut, ReadTimeout, ReadFailure, \ WriteTimeout, WriteFailure -from cassandra.cluster import Cluster, NoHostAvailable +from cassandra.cluster import Cluster, NoHostAvailable, Session from cassandra.concurrent import execute_concurrent_with_args from cassandra.metadata import murmur3 from cassandra.policies import (RoundRobinPolicy, DCAwareRoundRobinPolicy, @@ -426,7 +426,7 @@ class LoadBalancingPolicyTests(unittest.TestCase): self._query(session, keyspace, use_prepared=use_prepared) self.fail() except Unavailable as e: - self.assertEqual(e.consistency, 1) + self.assertEqual(e.consistency, Session.default_consistency_level) self.assertEqual(e.required_replicas, 1) self.assertEqual(e.alive_replicas, 0) diff --git a/tests/integration/standard/test_metadata.py b/tests/integration/standard/test_metadata.py index c8d726d1..98a9945f 100644 --- a/tests/integration/standard/test_metadata.py +++ b/tests/integration/standard/test_metadata.py @@ -693,6 +693,9 @@ class SchemaMetadataTests(BasicSegregatedKeyspaceUnitTestCase): @test_category metadata """ + if CASS_SERVER_VERSION < (3, 0): + raise unittest.SkipTest("Materialized views require Cassandra 3.0+") + self.session.execute("CREATE TABLE {0}.{1} (a int PRIMARY KEY, b map)".format(self.keyspace_name, self.function_table_name)) self.session.execute("CREATE INDEX index_1 ON {0}.{1}(b)".format(self.keyspace_name, self.function_table_name)) self.session.execute("CREATE INDEX index_2 ON {0}.{1}(keys(b))".format(self.keyspace_name, self.function_table_name))