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

Don't omit ignored nodes from schema agreement, if they're up

Browse Source 
see #615
This commit is contained in:
Adam Holmberg
2016-07-08 16:49:30 -05:00
parent d30f67e554
commit 3c5266093e
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cassandra/cluster.py
View File

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