| Index: task_scheduler/go/scheduling/task_scheduler.go
|
| diff --git a/build_scheduler/go/task_scheduler/task_scheduler.go b/task_scheduler/go/scheduling/task_scheduler.go
|
| similarity index 99%
|
| rename from build_scheduler/go/task_scheduler/task_scheduler.go
|
| rename to task_scheduler/go/scheduling/task_scheduler.go
|
| index 12fdffc7614a185411a1942bfe090147768c0885..7a8c2d7cf8a440c387709d32d5aebcfec7c7b820 100644
|
| --- a/build_scheduler/go/task_scheduler/task_scheduler.go
|
| +++ b/task_scheduler/go/scheduling/task_scheduler.go
|
| @@ -1,4 +1,4 @@
|
| -package task_scheduler
|
| +package scheduling
|
|
|
| import (
|
| "fmt"
|
| @@ -10,7 +10,6 @@ import (
|
|
|
| swarming_api "github.com/luci/luci-go/common/api/swarming/swarming/v1"
|
| "github.com/skia-dev/glog"
|
| - "go.skia.org/infra/build_scheduler/go/db"
|
| "go.skia.org/infra/go/buildbot"
|
| "go.skia.org/infra/go/gitinfo"
|
| "go.skia.org/infra/go/gitrepo"
|
| @@ -19,6 +18,7 @@ import (
|
| "go.skia.org/infra/go/swarming"
|
| "go.skia.org/infra/go/timer"
|
| "go.skia.org/infra/go/util"
|
| + "go.skia.org/infra/task_scheduler/go/db"
|
| )
|
|
|
| // TaskScheduler is a struct used for scheduling tasks on bots.
|
| @@ -462,7 +462,7 @@ func (s *TaskScheduler) regenerateTaskQueue() error {
|
| // candidates in the queue and returns the candidates which should be run.
|
| // Assumes that the tasks are sorted in decreasing order by score.
|
| func getCandidatesToSchedule(bots []*swarming_api.SwarmingRpcsBotInfo, tasks []*taskCandidate) []*taskCandidate {
|
| - defer timer.New("task_scheduler.getCandidatesToSchedule").Stop()
|
| + defer timer.New("scheduling.getCandidatesToSchedule").Stop()
|
| // Create a bots-by-swarming-dimension mapping.
|
| botsByDim := map[string]util.StringSet{}
|
| for _, b := range bots {
|
|
|