diff --git a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
index 144d6d4..91aecaf 100644
--- a/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
+++ b/azkaban-common/src/main/java/azkaban/executor/ExecutorManager.java
@@ -536,21 +536,14 @@ public class ExecutorManager extends EventHandler implements
}
/**
- * Fetch ExecutableFlow from an active (running, non-dispatched) or from
- * database {@inheritDoc}
+ * Fetch ExecutableFlow from database {@inheritDoc}
*
* @see azkaban.executor.ExecutorManagerAdapter#getExecutableFlow(int)
*/
@Override
public ExecutableFlow getExecutableFlow(int execId)
throws ExecutorManagerException {
- if (runningFlows.containsKey(execId)) {
- return runningFlows.get(execId).getSecond();
- } else if (queuedFlows.hasExecution(execId)) {
- return queuedFlows.getFlow(execId);
- } else {
return executorLoader.fetchExecutableFlow(execId);
- }
}
/**
