protected Future evaluate()

in src/main/java/com/twitter/nodes/BaseTransformNode.java [51:67]

• 14 lines of code
• 2 McCabe index (conditional complexity)

  protected Future<Resp> evaluate() throws Exception {
    SourceType source = node.emit();

    Future<Resp> resp;

    try {
      resp = transform(source);
    } catch (Exception e) {
      String msg = String.format(
          "TransformNode [%s] on [%s] threw an exception while transforming (%s): %s",
          getName(), node.getName(), e, String.valueOf(source));
      LOG.error(e, msg);
      return Future.exception(new RuntimeException(msg, e));
    }

    return resp;
  }