Changed FlowParser to always include a transition for COMPLETED unless a next attribute is present
This commit is contained in:
@@ -167,10 +167,6 @@ public class FlowParser extends AbstractFlowParser {
|
||||
stateDef, parserContext, false));
|
||||
list.addAll(createTransition(FlowExecutionStatus.UNKNOWN, FlowExecutionStatus.UNKNOWN.getName(), null, null,
|
||||
stateDef, parserContext, false));
|
||||
if (!hasNextAttribute) {
|
||||
list.addAll(createTransition(FlowExecutionStatus.COMPLETED, FlowExecutionStatus.COMPLETED.getName(), null, null, stateDef, parserContext,
|
||||
false));
|
||||
}
|
||||
}
|
||||
|
||||
if (hasNextAttribute) {
|
||||
@@ -180,6 +176,9 @@ public class FlowParser extends AbstractFlowParser {
|
||||
}
|
||||
|
||||
list.add(getStateTransitionReference(parserContext, stateDef, null, shortNextAttribute));
|
||||
} else {
|
||||
list.addAll(createTransition(FlowExecutionStatus.COMPLETED, FlowExecutionStatus.COMPLETED.getName(), null, null, stateDef, parserContext,
|
||||
false));
|
||||
}
|
||||
|
||||
return list;
|
||||
|
||||
@@ -71,14 +71,14 @@ public class DecisionStepTests {
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testDecisionInvalidExitStatus() throws Exception {
|
||||
public void testDecisionUnmappedExitStatus() throws Exception {
|
||||
ApplicationContext context = new GenericXmlApplicationContext("classpath:/org/springframework/batch/core/jsr/step/DecisionStepTests-decisionInvalidExitStatus-context.xml");
|
||||
|
||||
JobLauncher launcher = context.getBean(JobLauncher.class);
|
||||
Job job = context.getBean(Job.class);
|
||||
|
||||
JobExecution execution = launcher.run(job, new JobParameters());
|
||||
assertEquals(BatchStatus.FAILED, execution.getStatus());
|
||||
assertEquals(BatchStatus.COMPLETED, execution.getStatus());
|
||||
assertEquals(2, execution.getStepExecutions().size());
|
||||
|
||||
for (org.springframework.batch.core.StepExecution curExecution : execution.getStepExecutions()) {
|
||||
|
||||
Reference in New Issue
Block a user