Method singleRun

pkg/routine/instance.go:60–85

Performs a single run. That is, to try to obtain the lock and run the routine until it returns. Return the backoff duration after which another single run should be performed.

(ctx context.Context)

// until it returns. Return the backoff duration after which another single run
// should be performed.
func (r *routineThatKeepsRunningOneInstance) singleRun(ctx context.Context) time.Duration {
	l := redis.NewLock("routine:lock:"+r.Name, redis.SetTTL(r.lockTTL))
	lockCtx, cancel, err := l.AcquireAndKeepUp(ctx)
	if err != nil {
		go errors.Handle(ctx, err) // report error to Sentry, non-blocking
		return r.backoff.Duration("lock")
	}
	if lockCtx != nil {
		defer cancel()
		routinePanicked := true
		func() {
			defer errors.HandleWithCtx(ctx, fmt.Sprintf("routine %d", r.num)) // handle panics

			span := sentry.StartSpan(lockCtx, "function", sentry.WithDescription(fmt.Sprintf("routine %d", r.num)))
			defer span.Finish()

			r.Routine(span.Context())
			routinePanicked = false
		}()
		if routinePanicked {
			return r.backoff.Duration("routine")
		}
	}
	r.backoff.ResetAll()
	return r.retryInterval
}