Merge pull request #1981 from yershalom/upgrade_cassandra_version

Upgrade cassandra version
This commit is contained in:
Arik Fraimovich 2017-10-09 11:39:03 +03:00 committed by GitHub
commit cb21024e5c
2 changed files with 7 additions and 1 deletions

View File

@ -60,6 +60,11 @@ class Cassandra(BaseQueryRunner):
'type': 'number', 'type': 'number',
'title': 'Protocol Version', 'title': 'Protocol Version',
'default': 3 'default': 3
},
'timeout': {
'type': 'number',
'title': 'Timeout',
'default': 10
} }
}, },
'required': ['keyspace', 'host'] 'required': ['keyspace', 'host']
@ -119,6 +124,7 @@ class Cassandra(BaseQueryRunner):
protocol_version=self.configuration.get('protocol', 3)) protocol_version=self.configuration.get('protocol', 3))
session = connection.connect() session = connection.connect()
session.set_keyspace(self.configuration['keyspace']) session.set_keyspace(self.configuration['keyspace'])
session.default_timeout = self.configuration.get('timeout', 10)
logger.debug("Cassandra running query: %s", query) logger.debug("Cassandra running query: %s", query)
result = session.execute(query) result = session.execute(query)

View File

@ -16,7 +16,7 @@ botocore==1.5.72
sasl>=0.1.3 sasl>=0.1.3
thrift>=0.8.0 thrift>=0.8.0
thrift_sasl>=0.1.0 thrift_sasl>=0.1.0
cassandra-driver==3.1.1 cassandra-driver==3.11.0
memsql==2.16.0 memsql==2.16.0
atsd_client==2.0.12 atsd_client==2.0.12
simple_salesforce==0.72.2 simple_salesforce==0.72.2