}
@Override
public PipelineResult run() {
try {
PipelineExecution pipelineExecution = runAsync();
pipelineExecution.waitUntilDone();
return pipelineExecution.getResult();
} catch (InterruptedException e) {
// TODO: How to handle this without changing signature?
LOG.error("Exception running pipeline", e);
return PipelineResult.EMPTY;
}