Method CompleteJob

modules/backendscheduler/work/work.go:319–336

CompleteJob marks a job as completed in the appropriate shard

(id string)

// CompleteJob marks a job as completed in the appropriate shard
func (w *Work) CompleteJob(id string) {
	shard := w.getShard(id)
	shard.mtx.Lock()
	var j *Job
	if jj, ok := shard.Jobs[id]; ok {
		jj.Complete()
		j = jj
	}
	shard.mtx.Unlock()

	if j != nil {
		w.pendingMtx.Lock()
		for _, key := range runningBlockKeys(j) {
			delete(w.runningBlocks, key)
		}
		w.pendingMtx.Unlock()
	}
}

// FailJob marks a job as failed in the appropriate shard
func (w *Work) FailJob(id string) {