code: def watchdog_handler(self):
          
          _LOGGING.debug('%s Watchdog expired. Resetting connection.', self.name)
          self.watchdog.stop()
          self.reset_thrd.set()
docs: Take care of threads if wachdog expires.