async def _periodically_cleanup(self) -> None:
    while (not self.is_closed):
        cleanup_interval = 1800
        max_timestamp_difference = ((14 * 3600) * 24)
        max_consecutive_failures = 10
        (await asyncio.sleep(cleanup_interval))
        full_node_connected = self.server.get_full_node_connections()
        connected = [c.get_peer_info() for c in full_node_connected]
        connected = [c for c in connected if (c is not None)]
        if ((self.address_manager is not None) and (len(connected) >= 3)):
            async with self.address_manager.lock:
                self.address_manager.cleanup(max_timestamp_difference, max_consecutive_failures)
async def _periodically_cleanup(self) -> None:
    while (not self.is_closed):
        cleanup_interval = 1800
        max_timestamp_difference = ((14 * 3600) * 24)
        max_consecutive_failures = 10
        (await asyncio.sleep(cleanup_interval))
        full_node_connected = self.server.get_full_node_connections()
        connected = [c.get_peer_info() for c in full_node_connected]
        connected = [c for c in connected if (c is not None)]
        if ((self.address_manager is not None) and (len(connected) >= 3)):
            async with self.address_manager.lock:
                self.address_manager.cleanup(max_timestamp_difference, max_consecutive_failures)