Added taskExecutionStatus to TaskExecutionThinResource. (#5781)

spring-cloud-dataflow-rest-resource/src/main/java/org/springframework/cloud/dataflow/rest/resource/TaskExecutionThinResource.java

@@ -20,6 +20,7 @@
 import org.springframework.cloud.dataflow.schema.AggregateTaskExecution;
 import org.springframework.hateoas.PagedModel;
 import org.springframework.hateoas.RepresentationModel;
+import org.springframework.util.StringUtils;
 
 /**
  * This resource is a match for AggregateTaskExecution and should satisfy UI paging.
@@ -66,6 +67,8 @@ public class TaskExecutionThinResource extends RepresentationModel<TaskExecution
 
 	private String errorMessage;
 
+	private String taskExecutionStatus;
+
 	/**
 	 * @since 2.11.0
 	 */
@@ -178,6 +181,39 @@ public String getPlatformName() {
 	public void setPlatformName(String platformName) {
 		this.platformName = platformName;
 	}
+	public void setTaskExecutionStatus(String taskExecutionStatus) {
+		this.taskExecutionStatus = taskExecutionStatus;
+	}
+
+	/**
+	 * Returns the calculated status of this {@link TaskExecution}.
+	 *
+	 * If {@link #startTime} is
+	 * null, the {@link TaskExecution} is considered to be not running (never executed).
+	 *
+	 * If {@link #endTime} is
+	 * null, the {@link TaskExecution} is considered to be still running:
+	 * {@link TaskExecutionStatus#RUNNING}. If the {@link #endTime} is defined and the
+	 * {@link #exitCode} is non-zero, an status of {@link TaskExecutionStatus#ERROR} is assumed,
+	 * if {@link #exitCode} is zero, {@link TaskExecutionStatus#COMPLETE} is returned.
+	 *
+	 * @return TaskExecutionStatus, never null
+	 */
+	public TaskExecutionStatus getTaskExecutionStatus() {
+		if (StringUtils.hasText(this.taskExecutionStatus)) {
+			return TaskExecutionStatus.valueOf(this.taskExecutionStatus);
+		}
+		if (this.startTime == null) {
+			return TaskExecutionStatus.UNKNOWN;
+		}
+		if (this.endTime == null) {
+			return TaskExecutionStatus.RUNNING;
+		}
+
+		return (this.exitCode == null) ? TaskExecutionStatus.RUNNING :
+				((this.exitCode == 0) ? TaskExecutionStatus.COMPLETE : TaskExecutionStatus.ERROR);
+	}
+
 	public static class Page extends PagedModel<TaskExecutionThinResource> {
 	}
 }