AlertOnStaleOrExpiredDatasets.java

@Override
public Unit process() {
  Set<Method> annotatedMethods = reflections.getMethodsAnnotatedWith(annotationClass);
  Set<Field> annotatedFields = reflections.getFieldsAnnotatedWith(annotationClass);
  List<DataSet> dataSets = Sets.union(annotatedFields, annotatedMethods).stream()
      .map(this::buildDataSet)
      .sorted(Comparator.comparing(DataSet::getStaleAt))
      .toList();

  Multimap<Author, StaleDatasetRow> authorToStaleDatasetRows = ArrayListMultimap.create();

  for (DataSet dataSet : dataSets) {
    for (StaleDatasetRow staleDatasetRow : dataSet.toReportRowIfStale()) {
      authorToStaleDatasetRows.put(dataSet.getAuthor(), staleDatasetRow);
    }
    dataSet.pageIfExpired();
  }

  maybeSendStalenessReport(authorToStaleDatasetRows);
  return Unit.unit;
}