in src/main/java/com/uber/cadence/internal/testservice/TestWorkflowMutableStateImpl.java [419:479]
private void processDecision(
RequestContext ctx, Decision d, String identity, long decisionTaskCompletedId)
throws BadRequestError, InternalServiceError {
switch (d.getDecisionType()) {
case CompleteWorkflowExecution:
processCompleteWorkflowExecution(
ctx,
d.getCompleteWorkflowExecutionDecisionAttributes(),
decisionTaskCompletedId,
identity);
break;
case FailWorkflowExecution:
processFailWorkflowExecution(
ctx, d.getFailWorkflowExecutionDecisionAttributes(), decisionTaskCompletedId, identity);
break;
case CancelWorkflowExecution:
processCancelWorkflowExecution(
ctx, d.getCancelWorkflowExecutionDecisionAttributes(), decisionTaskCompletedId);
break;
case ContinueAsNewWorkflowExecution:
processContinueAsNewWorkflowExecution(
ctx,
d.getContinueAsNewWorkflowExecutionDecisionAttributes(),
decisionTaskCompletedId,
identity);
break;
case ScheduleActivityTask:
processScheduleActivityTask(
ctx, d.getScheduleActivityTaskDecisionAttributes(), decisionTaskCompletedId);
break;
case RequestCancelActivityTask:
processRequestCancelActivityTask(
ctx, d.getRequestCancelActivityTaskDecisionAttributes(), decisionTaskCompletedId);
break;
case StartTimer:
processStartTimer(ctx, d.getStartTimerDecisionAttributes(), decisionTaskCompletedId);
break;
case CancelTimer:
processCancelTimer(ctx, d.getCancelTimerDecisionAttributes(), decisionTaskCompletedId);
break;
case StartChildWorkflowExecution:
processStartChildWorkflow(
ctx, d.getStartChildWorkflowExecutionDecisionAttributes(), decisionTaskCompletedId);
break;
case SignalExternalWorkflowExecution:
processSignalExternalWorkflowExecution(
ctx, d.getSignalExternalWorkflowExecutionDecisionAttributes(), decisionTaskCompletedId);
break;
case RecordMarker:
processRecordMarker(ctx, d.getRecordMarkerDecisionAttributes(), decisionTaskCompletedId);
break;
case RequestCancelExternalWorkflowExecution:
processRequestCancelExternalWorkflowExecution(
ctx, d.getRequestCancelExternalWorkflowExecutionDecisionAttributes());
break;
case UpsertWorkflowSearchAttributes:
processUpsertWorkflowSearchAttributes(
ctx, d.getUpsertWorkflowSearchAttributesDecisionAttributes(), decisionTaskCompletedId);
break;
}
}