def upgradeObservations(context, logger):
    """ check if any observation has old country assignments
    """
    COUNTRIES = {'au': 'at', 'cr': 'hr', 'et': 'ee', 'sv': 'sk'}
    brains = context.portal_catalog.unrestrictedSearchResults(portal_type=
        'Observation', Country=COUNTRIES.keys())
    for brain in brains:
        observation = brain.getObject()
        old = observation.country
        new = COUNTRIES.get(old)
        observation.country = new
        logger.info('Country set for %s (%s -> %s)' % (observation.id, old,
            new))
