doComplexJobTest(-5, 71, 6);
}
private void doComplexJobTest(int x, int y, int z) throws Exception {
PipelineService service = PipelineServiceFactory.newPipelineService();
String pipelineId = service.startNewPipeline(new ComplexJob(), x, y, z);
JobInfo jobInfo = service.getJobInfo(pipelineId);
JobInfo.State state = jobInfo.getJobState();
if (JobInfo.State.COMPLETED_SUCCESSFULLY == state) {
System.out.println("The output is " + jobInfo.getOutput());
}