def METHOD_NAME(context: TaskContext) -> None:
    for org_volumes in TimedIterator(
        context,
        GetActiveOrgsVolumes(
            max_orgs=CHUNK_SIZE,
            time_interval=RECALIBRATE_ORGS_QUERY_INTERVAL,
            granularity=Granularity(60),
        ),
    ):
        for org_volume in org_volumes:
            try:
                recalibrate_org(org_volume, context)
            except RecalibrationError as e:
                sentry_sdk.set_extra("context-data", context.to_dict())
                log_recalibrate_org_error(org_volume.org_id, str(e))