Method SetRetry

internal/task/base.go:68–80

(retry int, maxRetry int)

}

func (t *TaskExtension) SetRetry(retry int, maxRetry int) {
	t.Base.SetRetry(retry, maxRetry)
	if retry > 0 || !conf.Conf.Tasks.AllowRetryCanceled || t.Ctx() == nil {
		return
	}
	select {
	case <-t.Ctx().Done():
		ctx, cancel := context.WithCancel(context.Background())
		t.SetCtx(ctx)
		t.SetCancelFunc(cancel)
	default:
	}
}

type TaskExtensionInfo interface {
	tache.TaskWithInfo