Function jobPruningWorker

pkg/jobcontroller/jobcontroller.go:303–315

()

}

func jobPruningWorker() {
	defer func() {
		panichandler.PanicHandler("jobcontroller:jobPruningWorker", recover())
	}()

	ticker := time.NewTicker(1 * time.Minute)
	defer ticker.Stop()

	var previousCandidates []string
	for range ticker.C {
		previousCandidates = pruneUnusedJobs(previousCandidates)
	}
}

func pruneUnusedJobs(previousCandidates []string) []string {
	ctx, cancelFn := context.WithTimeout(context.Background(), 30*time.Second)