Ensure we can connect to a Cassandra node version > 3

2016-09-29 15:10:04 -04:00
parent b862c2a4fc
commit 8289de0b38
1 changed files with 2 additions and 1 deletions
--- a/cassandra/metadata.py
+++ b/cassandra/metadata.py
@@ -2487,7 +2487,8 @@ class MaterializedViewMetadata(object):


 def get_schema_parser(connection, server_version, timeout):
-    if server_version.startswith('3'):
+    server_major_version = int(server_version.split('.')[0])
+    if server_major_version >= 3:
        return SchemaParserV3(connection, timeout)
    else:
        # we could further specialize by version. Right now just refactoring the