Method RegisterJob

modules/backendscheduler/work/work.go:134–141

RegisterJob registers a job before it enters the channel pipeline, making it visible to other components (e.g. HasJobsForTenant, BusyBlocksForTenant). Call this immediately after creating a job, before sending it to the jobs channel. The registration is cleared automatically when AddJob promotes the

(job *Job)

// Call this immediately after creating a job, before sending it to the jobs channel.
// The registration is cleared automatically when AddJob promotes the job to active.
func (w *Work) RegisterJob(job *Job) {
	w.pendingMtx.Lock()
	w.registeredJobs[job.ID] = job
	for _, key := range runningBlockKeys(job) {
		w.runningBlocks[key] = job
	}
	w.pendingMtx.Unlock()
}

// FlushToLocal writes the work cache to local storage using sharding optimizations
func (w *Work) FlushToLocal(_ context.Context, localPath string, affectedJobIDs []string) error {