async def METHOD_NAME(self):
    while True:
        if self._shut_down:
            return None
        try:
            for i in range(60):
                if self._shut_down:
                    return None
                await asyncio.sleep(1)
            self.log.info("Vetting random peers.")
            if self._server.introducer_peers is None:
                continue
            raw_peers = self.server.introducer_peers.get_peers(100, True, 3 * self.recent_peer_threshold)
            if len(raw_peers) == 0:
                continue
            peer: VettedPeer
            for peer in raw_peers:
                if self._shut_down:
                    return None
                now = time.time()
                # if it was too long ago we checked this peer, check it
                # again
                if peer.vetted > 0 and now > peer.vetted_timestamp + 3600:
                    peer.vetted = 0
                if peer.vetted > 0:
                    continue
                # don't re-vet peers too frequently
                if now < peer.last_attempt + 500:
                    continue
                try:
                    peer.last_attempt = uint64(time.time())
                    self.log.info(f"Vetting peer {peer.host} {peer.port}")
                    r, w = await asyncio.wait_for(
                        asyncio.open_connection(peer.host, int(peer.port)),
                        timeout=3,
                    )
                    w.close()
                except Exception as e:
                    self.log.warning(f"Could not vet {peer}, removing. {type(e)}{str(e)}")
                    peer.vetted = min(peer.vetted - 1, -1)
                    # if we have failed 6 times in a row, remove the peer
                    if peer.vetted < -6:
                        self.server.introducer_peers.remove(peer)
                    continue
                self.log.info(f"Have vetted {peer} successfully!")
                peer.vetted_timestamp = uint64(time.time())
                peer.vetted = max(peer.vetted + 1, 1)
        except Exception as e:
            self.log.error(e)