def METHOD_NAME(self):
    log.info("Start watching cluster lock %s", self._lease)
    with self._cond:
        if self._running:
            raise RuntimeError("Watchdog already started")
        self._thread.METHOD_NAME()
        self._running = True