Compatibility with old kazoo (#468)

```python
AttributeError: 'KazooClient' object has no attribute '_retry'
```

Fixes #467
This commit is contained in:
jouir
2017-07-04 16:13:18 +02:00
committed by Alexander Kukushkin
parent 23e6f65156
commit b60f65a2ca
+2 -1
View File
@@ -116,7 +116,8 @@ class ZooKeeper(AbstractDCS):
return True
def set_retry_timeout(self, retry_timeout):
self._client._retry.deadline = retry_timeout
retry = self._client.retry if isinstance(self._client.retry, KazooRetry) else self._client._retry
retry.deadline = retry_timeout
def get_node(self, key, watch=None):
try: