summaryrefslogtreecommitdiff
path: root/tooz/drivers/memcached.py
diff options
context:
space:
mode:
Diffstat (limited to 'tooz/drivers/memcached.py')
-rw-r--r--tooz/drivers/memcached.py8
1 files changed, 7 insertions, 1 deletions
diff --git a/tooz/drivers/memcached.py b/tooz/drivers/memcached.py
index 7ee323c..661438f 100644
--- a/tooz/drivers/memcached.py
+++ b/tooz/drivers/memcached.py
@@ -229,6 +229,9 @@ class MemcachedDriver(coordination.CoordinationDriver):
return MemcachedFutureResult(self._executor.submit(_leave_group))
+ def _destroy_group(self, group_id):
+ self.client.delete(self._encode_group_id(group_id))
+
@_retry.retry
def _get_members(self, group_id):
encoded_group = self._encode_group_id(group_id)
@@ -337,7 +340,10 @@ class MemcachedDriver(coordination.CoordinationDriver):
def run_watchers(self):
result = []
for group_id in self.client.get(self._GROUP_LIST_KEY):
- group_members = set(self._get_members(group_id))
+ try:
+ group_members = set(self._get_members(group_id))
+ except coordination.GroupNotCreated:
+ group_members = set()
old_group_members = self._group_members[group_id]
for member_id in (group_members - old_group_members):