OLD | NEW |
1 package task_scheduler | 1 package scheduling |
2 | 2 |
3 import ( | 3 import ( |
4 "encoding/json" | 4 "encoding/json" |
5 "fmt" | 5 "fmt" |
6 "io/ioutil" | 6 "io/ioutil" |
7 "math" | 7 "math" |
8 "os" | 8 "os" |
9 "path" | 9 "path" |
10 "path/filepath" | 10 "path/filepath" |
11 "runtime" | 11 "runtime" |
12 "sort" | 12 "sort" |
13 "strings" | 13 "strings" |
14 "testing" | 14 "testing" |
15 "time" | 15 "time" |
16 | 16 |
17 swarming_api "github.com/luci/luci-go/common/api/swarming/swarming/v1" | 17 swarming_api "github.com/luci/luci-go/common/api/swarming/swarming/v1" |
18 assert "github.com/stretchr/testify/require" | 18 assert "github.com/stretchr/testify/require" |
19 "go.skia.org/infra/build_scheduler/go/db" | |
20 "go.skia.org/infra/go/buildbot" | 19 "go.skia.org/infra/go/buildbot" |
21 "go.skia.org/infra/go/exec" | 20 "go.skia.org/infra/go/exec" |
22 "go.skia.org/infra/go/gitinfo" | 21 "go.skia.org/infra/go/gitinfo" |
23 "go.skia.org/infra/go/gitrepo" | 22 "go.skia.org/infra/go/gitrepo" |
24 "go.skia.org/infra/go/isolate" | 23 "go.skia.org/infra/go/isolate" |
25 "go.skia.org/infra/go/swarming" | 24 "go.skia.org/infra/go/swarming" |
26 "go.skia.org/infra/go/testutils" | 25 "go.skia.org/infra/go/testutils" |
27 "go.skia.org/infra/go/util" | 26 "go.skia.org/infra/go/util" |
| 27 "go.skia.org/infra/task_scheduler/go/db" |
28 ) | 28 ) |
29 | 29 |
30 func makeTask(name, repo, revision string) *db.Task { | 30 func makeTask(name, repo, revision string) *db.Task { |
31 return &db.Task{ | 31 return &db.Task{ |
32 Commits: []string{revision}, | 32 Commits: []string{revision}, |
33 Created: time.Now(), | 33 Created: time.Now(), |
34 Name: name, | 34 Name: name, |
35 Repo: repo, | 35 Repo: repo, |
36 Revision: revision, | 36 Revision: revision, |
37 } | 37 } |
(...skipping 1346 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1384 assert.NoError(t, s.MainLoop()) | 1384 assert.NoError(t, s.MainLoop()) |
1385 assert.Equal(t, 0, len(s.queue)) | 1385 assert.Equal(t, 0, len(s.queue)) |
1386 tasks, err = cache.GetTasksForCommits(repoName, commits) | 1386 tasks, err = cache.GetTasksForCommits(repoName, commits) |
1387 assert.NoError(t, err) | 1387 assert.NoError(t, err) |
1388 for _, byName := range tasks { | 1388 for _, byName := range tasks { |
1389 for _, task := range byName { | 1389 for _, task := range byName { |
1390 assert.Equal(t, 1, len(task.Commits)) | 1390 assert.Equal(t, 1, len(task.Commits)) |
1391 } | 1391 } |
1392 } | 1392 } |
1393 } | 1393 } |
OLD | NEW |