azkaban-memoizeit

Removing bad check for failure

4/9/2013 9:25:20 PM

Details

diff --git a/src/java/azkaban/execapp/FlowRunner.java b/src/java/azkaban/execapp/FlowRunner.java
index 2386539..35b4afd 100644
--- a/src/java/azkaban/execapp/FlowRunner.java
+++ b/src/java/azkaban/execapp/FlowRunner.java
@@ -353,10 +353,7 @@ public class FlowRunner extends EventHandler implements Runnable {
 	private List<ExecutableNode> findReadyJobsToRun() {
 		ArrayList<ExecutableNode> jobsToRun = new ArrayList<ExecutableNode>();
 		for (ExecutableNode node : flow.getExecutableNodes()) {
-			if (node.getStatus() == Status.FAILED) {
-				
-			}
-			else if(Status.isStatusFinished(node.getStatus())) {
+			if (Status.isStatusFinished(node.getStatus())) {
 				continue;
 			}
 			else {
@@ -376,7 +373,7 @@ public class FlowRunner extends EventHandler implements Runnable {
 	private boolean isFlowFinished() {
 		for (String end: flow.getEndNodes()) {
 			ExecutableNode node = flow.getExecutableNode(end);
-			if (!Status.isStatusFinished(node.getStatus())) {
+			if (!Status.isStatusFinished(node.getStatus()) ) {
 				return false;
 			}
 		}