64
[]nexusoperationpb.CancellationStatus{nexusoperationpb.CANCELLATION_STATUS_SCHEDULED},
65
nexusoperationpb.CANCELLATION_STATUS_BACKING_OFF,
66
>
func(c *Cancellation, ctx chasm.MutableContext, event EventCancellationAttemptFailed) error {
cancellation_statemachine.go
67
>
currentTime := ctx.Now(c)
68
>
69
>
c.LastAttemptCompleteTime = timestamppb.New(currentTime)
70
>
c.LastAttemptFailure = event.Failure
71
>
72
>
nextDelay := event.RetryPolicy.ComputeNextDelay(0, int(c.Attempt), nil)
73
>
nextAttemptScheduleTime := currentTime.Add(nextDelay)
74
>
c.NextAttemptScheduleTime = timestamppb.New(nextAttemptScheduleTime)
75
>
76
>
ctx.AddTask(c, chasm.TaskAttributes{
77
>
ScheduledTime: nextAttemptScheduleTime,
78
>
}, &nexusoperationpb.CancellationBackoffTask{
79
>
Attempt: c.Attempt,
80
>
})
81
>
82
>
return nil
83
>
},
84
)
85