'Enter the barrier, blocks until all nodes have entered'

def enter(self):

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