Function pruneUnusedJobs

pkg/jobcontroller/jobcontroller.go:317–347

(previousCandidates []string)

}

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

	allJobs, err := wstore.DBGetAllObjsByType[*waveobj.Job](ctx, waveobj.OType_Job)
	if err != nil {
		log.Printf("[jobpruner] error getting all jobs: %v", err)
		return previousCandidates
	}

	var currentCandidates []string
	for _, job := range allJobs {
		if job.JobManagerStatus == JobManagerStatus_Done && job.AttachedBlockId == "" {
			currentCandidates = append(currentCandidates, job.OID)
		}
	}

	jobsToDelete := utilfn.StrSetIntersection(previousCandidates, currentCandidates)
	if len(previousCandidates) > 0 || len(currentCandidates) > 0 {
		log.Printf("[jobpruner] prev=%d current=%d deleting=%d", len(previousCandidates), len(currentCandidates), len(jobsToDelete))
	}

	for _, jobId := range jobsToDelete {
		err := DeleteJob(ctx, jobId)
		if err != nil {
			log.Printf("[jobpruner] error deleting job %s: %v", jobId, err)
		}
	}

	return currentCandidates
}

func handleRouteUpEvent(event *wps.WaveEvent) {
	handleRouteEvent(event, JobConnStatus_Connected)