anchor.diff:            .openRead()
             .transform(UTF8.decoder)
             .transform(new LineSplitter())
  -          .transform(new LogItemTransformer(allowNonSequentialMsgs: true))
  +          .transform(new LogItemTransformer())
             .handleError((e, s) {
           ++mapper.readFailureCount;
           print("Error reading line\n${trim300(e.toString())}\n$s");
  
positive.code:   print('----- reducing');
  
    // Initialize query specific objects
    var reducer = severeLogReducer;
    var reductionMerge = completionReductionMerge;
  
    // Reduce the information into two separate result maps
  
negative.code: import 'package:sintr_worker_lib/instrumentation_transformer.dart';
  import 'package:sintr_worker_lib/query.dart';
  import 'package:sintr_worker_lib/query/completion_metrics.dart';
  import 'package:sintr_worker_lib/session_info.dart';
  
  main(List<String> args) async {
  