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

Fix forgot to initialize HostConnection._is_replacing

Browse Source
This commit is contained in:
Roman Khanenko
2015-08-16 13:38:31 +03:00
parent 387689da00
commit 1289a00251
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cassandra/pool.py
View File

@@ -282,6 +282,7 @@ class HostConnection(object):
self.host_distance = host_distance self.host_distance = host_distance
self._session = weakref.proxy(session) self._session = weakref.proxy(session)
self._lock = Lock() self._lock = Lock()
self._is_replacing = False
if host_distance == HostDistance.IGNORED: if host_distance == HostDistance.IGNORED:
log.debug("Not opening connection to ignored host %s", self.host) log.debug("Not opening connection to ignored host %s", self.host)