async def METHOD_NAME(self):
    affect_roles = set()
    for address, info in self._node_infos.items():
        if (
            info.status == NodeStatus.READY
            and time.time() - info.update_time > self._node_timeout
        ):
            info.status = NodeStatus.STOPPED
            node_role = info.role
            affect_roles.add(node_role)
    if affect_roles:
        await self._notify_roles(affect_roles)
    self._check_task = self.ref().METHOD_NAME.tell_delay(
        delay=self._check_interval
    )