anchor.diff:  
     _TaskModel.fromData(
         this.parentJobName,
  -      String this.input,
  +      String input,
         Map<String, String> sources) {
       lifecycleState = _intFromLifecycle(LifecycleState.READY);
       lastUpdateEpochMs = new DateTime.now().millisecondsSinceEpoch;
       creationEpochMs = lastUpdateEpochMs;
       failureCount = 0;
       ownerID = _UNALLOCATED_OWNER;
  +
  +    inputBlob = GZIP.encode(UTF8.encode(input));
       sourceBlob = GZIP.encode(UTF8.encode(JSON.encode(sources)));
     }
   }
  
positive.code:     await _policyBasedSyncBackingStore();
      if (backingstore == null) return null;
  
      return backingstore.input;
    }
  
    Future<String> get result async {
  
negative.code:     await _policyBasedSyncBackingStore();
      if (backingstore == null) return null;
  
      return UTF8.decode(GZIP.decode(backingstore.outputBlob));
  
      // return backingstore.output;
    }
  
    Future setResult(String result) async {
      log.trace("Set result on Task for $_objectKey -> $result");
  
  
      backingstore.outputBlob = GZIP.encode(UTF8.encode(result));
      await _pushBackingStore();
      log.trace("Set result on Task for $_objectKey -> $result : OK");
    }
  