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

Merge pull request #617 from datastax/schema-agree-ignored

Browse Source 
Don't omit ignored nodes from schema agreement, if they're up
This commit is contained in:
Adam Holmberg
2016-07-18 09:58:20 -05:00
committed by GitHub
parent 7a18156c45 3c5266093e
commit d8d0456bad
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"):
versions[local_row.get("schema_version")].add(local_address)
pm = self._cluster.profile_manager
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 and pm.distance(peer) != HostDistance.IGNORED:
if peer and peer.is_up is not False:
versions[schema_ver].add(addr)
if len(versions) == 1: