From 8289de0b3858917e47e479dbc98dd9b4073f577e Mon Sep 17 00:00:00 2001 From: Alan Boudreault Date: Thu, 29 Sep 2016 15:10:04 -0400 Subject: [PATCH] Ensure we can connect to a Cassandra node version > 3 --- cassandra/metadata.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/cassandra/metadata.py b/cassandra/metadata.py index 67b6b850..eb8896d4 100644 --- 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