548
},
549
activitypb.ACTIVITY_EXECUTION_STATUS_PAUSED,
550
>
func(a *Activity, ctx chasm.MutableContext, event rescheduleEvent) error {
statemachine.go
551
>
attempt := a.LastAttempt.Get(ctx)
552
>
a.ResetKeepPaused = false
553
>
a.applyDeferredOptionRestore(ctx)
554
>
a.clearHeartbeatDetails(ctx)
555
>
attempt.Count = 1
556
>
attempt.Stamp++
557
>
if err := a.recordFailedAttempt(ctx, event.retryInterval, event.retryIntervalSource, event.failure, ctx.Now(a), false); err != nil {
558
return err
559
}
560
// Reset discards the retry backoff
562
>
attempt.CurrentRetryIntervalSource = activitypb.ACTIVITY_RETRY_INTERVAL_SOURCE_UNSPECIFIED
563
>
attempt.DispatchTime = nil
564
>
return nil
565
},
566
)