'Called during lock acquisition if a party change occurs'

def _abort_lock_acquisition(self):

    self._partition_set = []
    self._release_locks()
    if self._locks:
        self._fail_out()
        return
    return self._child_watching(self._allocate_transition)
