|
25 | 25 |
|
26 | 26 | from cassandra import AlreadyExists, SignatureDescriptor, UserFunctionDescriptor, UserAggregateDescriptor |
27 | 27 |
|
| 28 | + |
28 | 29 | from cassandra.cluster import Cluster |
29 | 30 | from cassandra.cqltypes import DoubleType, Int32Type, ListType, UTF8Type, MapType, LongType |
30 | 31 | from cassandra.encoder import Encoder |
|
33 | 34 | get_schema_parser) |
34 | 35 | from cassandra.policies import SimpleConvictionPolicy |
35 | 36 | from cassandra.pool import Host |
36 | | -from cassandra.query import SimpleStatement, ConsistencyLevel |
37 | 37 |
|
| 38 | +from cassandra.cython_deps import HAVE_CYTHON |
38 | 39 | from tests.integration import get_cluster, use_singledc, PROTOCOL_VERSION, get_server_versions, execute_until_pass, \ |
39 | | - BasicSharedKeyspaceUnitTestCase, BasicSegregatedKeyspaceUnitTestCase, BasicSharedKeyspaceUnitTestCase |
| 40 | + BasicSegregatedKeyspaceUnitTestCase, BasicSharedKeyspaceUnitTestCase, CASSANDRA_VERSION |
40 | 41 |
|
41 | 42 |
|
42 | 43 | def setup_module(): |
@@ -1680,6 +1681,7 @@ def test_return_type_meta(self): |
1680 | 1681 | with self.VerifiedAggregate(self, **self.make_aggregate_kwargs('sum_int', Int32Type, init_cond=1)) as va: |
1681 | 1682 | self.assertIs(self.keyspace_aggregate_meta[va.signature].return_type, Int32Type) |
1682 | 1683 |
|
| 1684 | + @unittest.skipUnless(CASSANDRA_VERSION >= '3.0.0', "Skiping until CASSANDRA-10365 is resolved") |
1683 | 1685 | def test_init_cond(self): |
1684 | 1686 | """ |
1685 | 1687 | Test to verify that various initial conditions are correctly surfaced in various aggregate functions |
@@ -1891,6 +1893,7 @@ def _skip_if_not_version(self, version): |
1891 | 1893 | if CASS_SERVER_VERSION < version: |
1892 | 1894 | raise unittest.SkipTest("Requires server version >= %s" % (version,)) |
1893 | 1895 |
|
| 1896 | + @unittest.skipIf(CASSANDRA_VERSION >= '3.0.0' and HAVE_CYTHON, "Skiping test due to python-422") |
1894 | 1897 | def test_bad_keyspace(self): |
1895 | 1898 | with patch.object(self.parser_class, '_build_keyspace_metadata_internal', side_effect=self.BadMetaException): |
1896 | 1899 | self.cluster.refresh_keyspace_metadata(self.keyspace_name) |
|
0 commit comments