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

don't check schema agreement with ignored hosts

Browse Source 
PYTHON-531
This commit is contained in:
Adam Holmberg
2016-04-29 09:54:40 -05:00
parent 01a38259e4
commit 1ad419bda4
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cassandra/cluster.py
View File

@@ -2569,13 +2569,14 @@ class ControlConnection(object):
if local_row.get("schema_version"):
versions[local_row.get("schema_version")].add(local_address)
lbp = self._cluster.load_balancing_policy
for row in peers_result:
schema_ver = row.get('schema_version')
if not schema_ver:
continue
addr = self._rpc_from_peer_row(row)
peer = self._cluster.metadata.get_host(addr)
if peer and peer.is_up:
if peer and peer.is_up and lbp.distance(peer) != HostDistance.IGNORED:
versions[schema_ver].add(addr)
if len(versions) == 1: