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

don't throw away a host that is in the contact points list

Browse Source
This commit is contained in:
Russ Bradberry
2013-12-12 16:48:10 -05:00
parent d68d8629a2
commit 7ec61e4d1a
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

@@ -1479,7 +1479,8 @@ class ControlConnection(object):
for old_host in self._cluster.metadata.all_hosts(): for old_host in self._cluster.metadata.all_hosts():
if old_host.address != connection.host and \ if old_host.address != connection.host and \
old_host.address not in found_hosts: old_host.address not in found_hosts and \
old_host.address not in self._cluster.contact_points:
log.debug("[control connection] Found host that has been removed: %r", old_host) log.debug("[control connection] Found host that has been removed: %r", old_host)
self._cluster.remove_host(old_host) self._cluster.remove_host(old_host)