Merge "watch_leave_group not triggering callback on expired members"

This commit is contained in:
Jenkins 2014-11-19 10:39:18 +00:00 committed by Gerrit Code Review
commit 1e4c1c9e84
1 changed files with 1 additions and 2 deletions

View File

@ -325,8 +325,7 @@ class MemcachedDriver(coordination.CoordinationDriver):
def run_watchers(self):
result = []
for group_id in self.client.get(self._GROUP_LIST_KEY):
encoded_group = self._encode_group_id(group_id)
group_members = set(self.client.get(encoded_group))
group_members = set(self._get_members(group_id))
old_group_members = self._group_members[group_id]
for member_id in (group_members - old_group_members):