async def METHOD_NAME(self, peer_info: PeerInfo) -> None:
    """
    connect ensures there is a connection between this host and the peer
    with given `peer_info.peer_id`. connect will absorb the addresses in
    peer_info into its internal peerstore. If there is not an active
    connection, connect will issue a dial, and block until a connection is
    opened, or an error is returned.
    :param peer_info: peer_info of the peer we want to connect to
    :type peer_info: peer.peerinfo.PeerInfo
    """
    self.peerstore.add_addrs(peer_info.peer_id, peer_info.addrs, 10)
    # there is already a connection to this peer
    if peer_info.peer_id in self._network.connections:
        return
    await self._network.dial_peer(peer_info.peer_id)