openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Accept CQL versions > 3.0.1

Browse Source
This commit is contained in:
Tyler Hobbs
2013-06-03 15:36:07 -05:00
parent 0233421076
commit 2d046080a3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
cassandra/connection.py
View File

@@ -122,7 +122,7 @@ class Connection(object):
in_buffer_size = 4096 in_buffer_size = 4096
out_buffer_size = 4096 out_buffer_size = 4096
cql_version = "3.0.1" cql_version = None
keyspace = None keyspace = None
compression = True compression = True
@@ -150,12 +150,12 @@ class Connection(object):
else: else:
return conn return conn
def __init__(self, host='127.0.0.1', port=9042, credentials=None, sockopts=None, compression=True): def __init__(self, host='127.0.0.1', port=9042, credentials=None, sockopts=None, compression=True, cql_version=None):
self.host = host self.host = host
self.port = port self.port = port
self.credentials = credentials self.credentials = credentials
self.compression = compression self.compression = compression
self.cql_version = cql_version
self.connected_event = Event() self.connected_event = Event()