37
38
for key, executable := range t.pendingExecutables {
39
>
if thisScope.Contains(executable) {
tracker.go
40
>
continue
41
}
42
43
>
if !thatScope.Contains(executable) {
tracker.go
44
panic(fmt.Sprintf("Queue slice encountered task doesn't belong to either scopes during split, scope: %v and %v, task: %v, task type: %v",
45
thisScope, thatScope, executable.GetTask(), executable.GetType()))
46
}
47
49
>
that.pendingExecutables[key] = executable
50
>
51
>
groupKey := t.grouper.Key(executable)
52
>
t.pendingPerKey[groupKey]--
53
>
that.pendingPerKey[groupKey]++
54
}
55