diff --git a/nflow-engine/src/main/java/io/nflow/engine/workflow/curated/CronWorkflow.java b/nflow-engine/src/main/java/io/nflow/engine/workflow/curated/CronWorkflow.java index 46cc563f3..99657a05d 100644 --- a/nflow-engine/src/main/java/io/nflow/engine/workflow/curated/CronWorkflow.java +++ b/nflow-engine/src/main/java/io/nflow/engine/workflow/curated/CronWorkflow.java @@ -103,12 +103,10 @@ protected CronWorkflow(String type, WorkflowSettings settings) { *
* public NextAction doWork(StateExecution execution) { * // do the work here - * if (waitForChildWorkflowsToFinish) { + * if (rescheduleImmediately) { * return NextAction.moveToState(schedule, "Work done"); - * } else { - * return NextAction.moveToStateAfter(waitForWorkToFinish, DateTime.now().plusHours(hoursToWait), - * "Waiting for work to finish"); * } + * return NextAction.moveToStateAfter(waitForWorkToFinish, DateTime.now().plusHours(hoursToWait), "Waiting for work to finish"); * } **