def METHOD_NAME(self):
    log.info("Stop watching cluster lock %s", self._lease)
    with self._cond:
        if not self._running:
            return
        self._running = False
        self._cond.notify()
    self._thread.join()