Function runningBlockKeys

modules/backendscheduler/work/work.go:834–844

runningBlockKeys returns pendingBlockKey strings for every block referenced by j.

(j *Job)

// runningBlockKeys returns pendingBlockKey strings for every block referenced by j.
func runningBlockKeys(j *Job) []string {
	tenant := j.Tenant()
	var keys []string
	for _, bid := range j.GetCompactionInput() {
		keys = append(keys, pendingBlockKey(tenant, bid))
	}
	if bid := j.GetRedactionBlockID(); bid != "" {
		keys = append(keys, pendingBlockKey(tenant, bid))
	}
	return keys
}

func (w *Work) removePendingBlockIndex(j *Job) {
	key := j.PendingBlockKey()