Merge pull request #670 from lastfm/master
Fixup attribute name on cluster reconnect
This commit is contained in:
@@ -2693,7 +2693,7 @@ class ControlConnection(object):
|
|||||||
self._set_new_connection(self._reconnect_internal())
|
self._set_new_connection(self._reconnect_internal())
|
||||||
except NoHostAvailable:
|
except NoHostAvailable:
|
||||||
# make a retry schedule (which includes backoff)
|
# make a retry schedule (which includes backoff)
|
||||||
schedule = self.cluster.reconnection_policy.new_schedule()
|
schedule = self._cluster.reconnection_policy.new_schedule()
|
||||||
|
|
||||||
with self._reconnection_lock:
|
with self._reconnection_lock:
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user