code: async def _watchdog(self, timeout):
          
          await asyncio.sleep(timeout, loop=self.loop)
          _LOGGER.debug("Watchdog triggered!")
          await self.cancel_watchdog()
          await self._watchdog_cb()
docs: Trigger and cancel the watchdog after timeout. Call callback.