624
var wfStatus enumspb.WorkflowExecutionStatus
625
switch outcome := info.Outcome.(type) {
626
>
case *persistencespb.ChasmNexusCompletion_Failure:
scheduler.go
627
>
previousResult := s.LastCompletionResult.Get(ctx) // Most-recent success is kept after failure.
628
>
wfStatus = executionStatusFromFailure(outcome.Failure)
629
>
s.LastCompletionResult = chasm.NewDataField(ctx, &schedulerpb.LastCompletionResult{
630
>
Failure: outcome.Failure,
631
>
Success: previousResult.Success,
632
>
})
633
case *persistencespb.ChasmNexusCompletion_Success:
634
wfStatus = enumspb.WORKFLOW_EXECUTION_STATUS_COMPLETED