'Leave the barrier, blocks until all nodes have left'

def leave(self):

    try:
        self.client.retry(self._inner_leave)
    except KazooException:
        self._best_effort_cleanup()
    self.participating = False
