Function DefaultStartTask

pkg/task/task.go:152–216

DefaultStartTask is the default TaskStarter.

(conf *Config)

// DefaultStartTask is the default TaskStarter.
func DefaultStartTask(conf *Config) {
	logger := log.FromContext(conf.Context).WithField("task_id", conf.ID)
	go func() {
		defer func() {
			if done := conf.Done; done != nil {
				done()
			}
		}()
		for invocation := uint(1); ; invocation++ {
			if invocation == 0 {
				logger.Warn("Invocation count rollover detected")
				invocation = 1
			}
			logger := logger.WithField("invocation", invocation)
			startTime := time.Now()
			err := conf.Func.Execute(conf.Context, logger)
			executionDuration := time.Since(startTime)
			// NOTE: We discard only the common errors here, instead of checking
			// the error code intentionally. The intent is to drop the commonly
			// met errors without hiding other errors with the canceled or deadline
			// exceeded error code.
			switch {
			case err == nil:
			case errors.Is(err, context.Canceled),
				errors.Is(err, errors.ErrContextCanceled),
				errors.Is(err, context.DeadlineExceeded),
				errors.Is(err, errors.ErrContextDeadlineExceeded):
			case errors.Is(err, io.EOF):
			default:
				logger.WithError(err).Warn("Task failed")
			}
			switch conf.Restart {
			case RestartNever:
				return
			case RestartAlways:
			case RestartOnFailure:
				if err == nil {
					return
				}
			default:
				panic("Invalid Config.Restart value")
			}
			select {
			case <-conf.Context.Done():
				return
			default:
			}
			if conf.Backoff == nil {
				continue
			}
			s := conf.Backoff.IntervalFunc(conf.Context, executionDuration, invocation, err)
			if s == 0 {
				continue
			}
			if conf.Backoff.Jitter != 0 {
				s = random.Jitter(s, conf.Backoff.Jitter)
			}
			select {