diff --git a/src/java/azkaban/execapp/FlowRunner.java b/src/java/azkaban/execapp/FlowRunner.java
index c91bb08..11d1d1b 100644
--- a/src/java/azkaban/execapp/FlowRunner.java
+++ b/src/java/azkaban/execapp/FlowRunner.java
@@ -694,6 +694,8 @@ public class FlowRunner extends EventHandler implements Runnable {
jobOutputProps.put(node.getJobId(), runner.getOutputProps());
}
+ updateFlow();
+
if (node.getStatus() == Status.FAILED) {
// Retry failure if conditions are met.
if (!runner.isCancelled() && runner.getRetries() > node.getAttempt()) {
