async def connection_check():
    while True:
        peer_retry = True
        for (_, connection) in server.all_connections.items():
            if ((connection.get_peer_info() == peer_info) or (connection.get_peer_info() == peer_info_arg)):
                peer_retry = False
        if peer_retry:
            log.info(f'Reconnecting to peer {peer_info}')
            try:
                (await server.start_client(peer_info, None, auth=auth))
            except Exception as e:
                log.info(f'Failed to connect to {peer_info} {e}')
        (await asyncio.sleep(3))
async def connection_check():
    while True:
        peer_retry = True
        for (_, connection) in server.all_connections.items():
            if ((connection.get_peer_info() == peer_info) or (connection.get_peer_info() == peer_info_arg)):
                peer_retry = False
        if peer_retry:
            log.info(f'Reconnecting to peer {peer_info}')
            try:
                (await server.start_client(peer_info, None, auth=auth))
            except Exception as e:
                log.info(f'Failed to connect to {peer_info} {e}')
        (await asyncio.sleep(3))