async def add_peers_neighbour(self, peers, neighbour_info):
    neighbour_data = (neighbour_info.host, neighbour_info.port)
    async with self.lock:
        for peer in peers:
            if (neighbour_data not in self.neighbour_known_peers):
                self.neighbour_known_peers[neighbour_data] = set()
            if (peer.host not in self.neighbour_known_peers[neighbour_data]):
                self.neighbour_known_peers[neighbour_data].add(peer.host)
async def add_peers_neighbour(self, peers, neighbour_info):
    neighbour_data = (neighbour_info.host, neighbour_info.port)
    async with self.lock:
        for peer in peers:
            if (neighbour_data not in self.neighbour_known_peers):
                self.neighbour_known_peers[neighbour_data] = set()
            if (peer.host not in self.neighbour_known_peers[neighbour_data]):
                self.neighbour_known_peers[neighbour_data].add(peer.host)