176
},
177
nexusoperationpb.OPERATION_STATUS_SUCCEEDED,
178
>
func(o *Operation, ctx chasm.MutableContext, event EventSucceeded) error {
operation_statemachine.go
179
>
// Clear the next attempt schedule time when leaving BACKING_OFF state. This field is only valid in
180
>
// BACKING_OFF state.
181
>
closeTime := ctx.Now(o)
182
>
if event.CompleteTime != nil {
183
closeTime = *event.CompleteTime
184
}
186
>
o.ClosedTime = timestamppb.New(closeTime)
187
>
188
>
o.getOrCreateOutcome(ctx).Variant = &nexusoperationpb.OperationOutcome_Successful_{
189
>
Successful: &nexusoperationpb.OperationOutcome_Successful{Result: event.Result},
190
>
}
191
>
192
>
o.emitOnSucceededMetrics(ctx, closeTime)
193
>
// Terminal state - no tasks to emit.
194
>
return nil
195
},
196
)