anchor.diff:  import 'package:sintr_common/logging_utils.dart' as log;
   import 'package:sintr_worker_lib/instrumentation_lib.dart';
   
  +import 'package:sintr_worker_lib/completion_metrics.dart'
  +    show
  +        completionExtraction,
  +        completionExtractionFinished,
  +        completionReducer,
  +        completionReductionMerge;
  +
   const projectName = "liftoff-dev";
  +var client;
   
   Future main(List<String> args, SendPort sendPort) async {
     ReceivePort receivePort = new ReceivePort();
  
positive.code: }
  
  Future<String> _protectedHandle(String msg) async {
    var processor = new LogItemProcessor();
  
    try {
      var inputData = JSON.decode(msg);
      String bucketName = inputData[0];
      String objectPath = inputData[1];
      var logItems = [];
      int failureCount = 0;
      int lines = 0;
  
      Stream dataStream = await getDataFromCloud(bucketName, objectPath);
      await for (String s in dataStream) {
        lines++;
        try {
          String result = processor.processLine(s);
          if (result != null) logItems.add(result);
        } catch (e, st) {
          failureCount++;
        }
      }
  
      try {
        String result = processor.close();
        if (result != null) logItems.add(result);
      } catch (e, st) {
        failureCount++;
      }
  
      return JSON.encode({
        "result": logItems,
        "failureCount": failureCount,
        "linesProcessed": lines
      });
    } catch (e, st) {
      log.info("Execution erred. $e \n $st \n");
      log.debug("Input data: $msg");
      return JSON.encode({"error": "${e}", "stackTrace": "${st}"});
    }
  
negative.code:       cryptoTokensLocation:
            "${config.userHomePath}/Communications/CryptoTokens");
  
    client = await auth.getAuthedClient();
    var sourceStorage = new storage.Storage(client, projectName);
    Stream<List<int>> rawStream =
        sourceStorage.bucket(bucketName).read(objectPath);
  