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

Merge pull request #653 from datastax/PYTHON-106-FIX

Browse Source 
Fix to keep type queries from breaking metadata construction in C* <2.1
This commit is contained in:
Greg Bestland
2016-08-23 14:22:19 -05:00
committed by GitHub
parent 1b53c7c154 c11b0c0dd0
commit 2cd415ebc6
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
cassandra/metadata.py
View File

@@ -1598,9 +1598,16 @@ class _SchemaParser(object):
def _query_build_rows(self, query_string, build_func): def _query_build_rows(self, query_string, build_func):
query = QueryMessage(query=query_string, consistency_level=ConsistencyLevel.ONE) query = QueryMessage(query=query_string, consistency_level=ConsistencyLevel.ONE)
response = self.connection.wait_for_response(query, self.timeout) responses = self.connection.wait_for_responses((query), timeout=self.timeout, fail_on_error=False)
result = dict_factory(*response.results) (success, response) = responses[0]
return [build_func(row) for row in result] if success:
result = dict_factory(*response.results)
return [build_func(row) for row in result]
elif isinstance(response, InvalidRequest):
log.debug("user types table not found")
return []
else:
raise response
class SchemaParserV22(_SchemaParser): class SchemaParserV22(_SchemaParser):