Working with task results

if (myTask.getTaskStatus() == TaskStatus.COMPLETED) {
    // Task executed successfully.
    // Process results.
} else {
    // There was an issue in the task.
    // Perform error handling.
}

public static class YourTask extends Task {
    @Override
    public void execute() {
        this.setResult("This is the result from the task.");
    }
}

public static class SimpleTask extends Task {
    @Override
    public void execute() {
        try {
            this.setResult(new MyTaskResult(InetAddress.getLocalHost().getHostName()));
        } catch (Exception e) {
        }
    }
}

public static class MyTaskResult implements Serializable  {
    private MyTaskResult() {}

    public GregorianCalendar time = new GregorianCalendar();
    public String machineName;
    public long tickCount;

    public MyTaskResult(String machineName) {
        this.time = new GregorianCalendar();
        this.machineName = machineName;
        this.tickCount = System.nanoTime();
    }
}

Task myTask = job.getTasks().get(0);
MyTaskResult result = (MyTaskResult) myTask.getResult();
// We have a copy of the object back
System.out.println("Time = " + result.time);
System.out.println("MachineName = " + result.machineName);
System.out.println("TickCont = " + result.tickCount);

public static class WritesToStandardOutput extends Task {
    @Override
    public void execute() {
        try {
            System.out.println("Current Time in task is: " + new GregorianCalendar());
            System.out.println("Agent MachineName: " + InetAddress.getLocalHost().getHostName());
            System.out.println("Current Tick Count is: " + System.currentTimeMillis() );
        } catch (Exception e) {
        }
    }
}

System.out.println("Standard Output =" + myTask.getStandardOutput());

public static class PropertiesExample extends Task {
    @Override
    public void execute() {
        this.setProperty("Property1", 100);
        this.setProperty("Property2", "hundred");
        this.setResult("This won't get back to the scheduler as we will see");
        throw new RuntimeException("Task failure");
    }
}

// After the task failed,
System.out.println("Task status = " + myTask.getTaskStatus());

// our Result property is an exception.
if (myTask.getResult() instanceof Throwable) {
    System.out.println("Exception is " + myTask.getResult());
}

// But we can get the properties object.
System.out.println("Property1: " + (Integer) myTask.getProperty("Property1"));
System.out.println("Property2: " + (String) myTask.getProperty("Property2"));

// Typical submit and wait pattern....
job.addTask(task);
job.submit();
job.waitUntilDone();

// After the task completes...
if (task.getTaskStatus() == TaskStatus.COMPLETED) {
    // Task ran without throwing an uncaught exception.
    // This is the only state where your Result object is guaranteed to be your user defined result.
    System.out.println("Task completed at " + task.getProperty(TaskProperties.HOST_END_TIME));
    System.out.println("Result: " + task.getResult());
} else if (task.getTaskStatus() == TaskStatus.FAILED) {
    // Task.execute threw an uncaught exception.
    // The result object is the exception that was not caught.
    System.out.println(String.format("Task (%s) threw an exception during Task.execute", task.getClass().getName()));
    System.out.println("Exception: " + task.getResult());
    System.out.println("StandardError with callstack: " + task.getStandardError());
} else if (task.getTaskStatus() == TaskStatus.ENVIRONMENT_ERROR) {
    // TaskEnvironment.setup threw an uncaught exception.
    // The result object is the exception that was not caught.
    System.out.println(String.format("TaskEnvironment (%s) thew an exception during TaskEnvironment.setup", job.getTaskEnvironment().getClass().getName()));
    System.out.println("Exception: " + task.getResult());
    System.out.println("StandardError with callstack: " + task.getStandardError());
} else if (task.getTaskStatus() == TaskStatus.TIMED_OUT) {
    // Task execution exceeded the value specified in Job.TaskExecutionTimeout
    // This should only be handled if you specify a value for Job.TaskExecutionTimeout
    System.out.println("Task execution exceeded the specified execution timeout");
    System.out.println("TaskExecutionTimeout was " + job.getTaskExecutionTimeout());
} else if (task.getTaskStatus() == TaskStatus.CANCELED) {
    // Task was canceled with Job.Cancel or by the user (for instance, the UI).
    // This should usually be handled if it is possible that users can cancel your task.
    System.out.println("Task was canceled");
    if (task.getTaskCancellationReason() == TaskCancellationReason.DIRECT) {
        System.out.println("User who canceled the task was: " + task.getTaskCancellationMessage());
    }
} else {
    // Any other state is not a final state, that is the task is still transitioning.
}