anchor.diff:      })) {
         lines++;
         // TODO (lukechurch): Add local error capture here
  -      var result = mapper.map(logEntry);
  -      if (result != null) {
  -        results.add(result);
  -      }
  +      mapper.map(logEntry);
       }
  -    results.addAll(mapper.cleanup());
  +    mapper.cleanup();
   
       return JSON.encode({
         "result": results,
  
positive.code:     int lines = 0;
  
      // Initialize query specific objects
      var mapper = new VersionMapper();
  
      Stream dataStream = await getDataFromCloud(bucketName, objectPath);
  
      // Extraction
      await mapper.init({});
      await for (String logEntry in dataStream
          .transform(UTF8.decoder)
          .transform(new LineSplitter())
  
negative.code: import 'package:sintr_common/configuration.dart' as config;
  import 'package:sintr_common/logging_utils.dart' as log;
  import 'package:sintr_worker_lib/instrumentation_transformer.dart';
  import 'package:sintr_worker_lib/query/completion_metrics.dart';
  import 'package:sintr_worker_lib/session_info.dart';
  
  const projectName = "liftoff-dev";
  var client;
  