Ensure we can connect to a Cassandra node version > 3

aboudreault · aboudreault · commit 8289de0b3858 · 2016-09-29T15:10:04.000-04:00
diff --git a/cassandra/metadata.py b/cassandra/metadata.py
@@ -2487,7 +2487,8 @@ def export_as_string(self):
 
 
 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
