def METHOD_NAME(oc, query, hpos):
    sys.stderr.write('Processing individuals...\n')
    individual_resp = oc.individuals.search(include='id,phenotypes', **query)
    for individual in individual_resp.result_iterator():
        sys.stderr.write('Fixing HPOs for individual "{}"\n'.format(individual['id']))
        if 'phenotypes' in individual and individual['phenotypes']:
            phenotypes = fix_phenotypes(individual['phenotypes'], hpos)
            oc.individuals.update(study=query['study'], individuals=individual['id'],
                                  data={'phenotypes': phenotypes})