Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(158)

Unified Diff: milo/appengine/swarming/build.go

Issue 2254993002: Milo: Add task expired as a failure status (Closed) Base URL: https://chromium.googlesource.com/external/github.com/luci/luci-go@master
Patch Set: Use proto instead Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « milo/appengine/logdog/logDogBuild.go ('k') | milo/appengine/swarming/expectations/build-expired.json » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: milo/appengine/swarming/build.go
diff --git a/milo/appengine/swarming/build.go b/milo/appengine/swarming/build.go
index afd1745f145a70d84d6db9685d48ea1466cd3795..be8b356f72ba9ab267cf81f2e6bbac006b725c3d 100644
--- a/milo/appengine/swarming/build.go
+++ b/milo/appengine/swarming/build.go
@@ -282,17 +282,23 @@ func addTaskToMiloStep(c context.Context, server string, sr *swarming.SwarmingRp
case TaskExpired, TaskTimedOut, TaskBotDied:
step.Status = miloProto.Status_FAILURE
- step.FailureDetails = &miloProto.FailureDetails{
- Type: miloProto.FailureDetails_INFRA,
- }
switch sr.State {
case TaskExpired:
- step.FailureDetails.Text = "Task expired"
+ step.FailureDetails = &miloProto.FailureDetails{
+ Type: miloProto.FailureDetails_EXPIRED,
+ Text: "Task expired",
+ }
case TaskTimedOut:
- step.FailureDetails.Text = "Task timed out"
+ step.FailureDetails = &miloProto.FailureDetails{
+ Type: miloProto.FailureDetails_INFRA,
+ Text: "Task timed out",
+ }
case TaskBotDied:
- step.FailureDetails.Text = "Bot died"
+ step.FailureDetails = &miloProto.FailureDetails{
+ Type: miloProto.FailureDetails_INFRA,
+ Text: "Bot died",
+ }
}
case TaskCanceled:
@@ -416,12 +422,14 @@ func swarmingBuildImpl(c context.Context, linkBase, server, taskID string) (*res
}
var build resp.MiloBuild
+ var s *miloProto.Step
+ var lds *logdog.Streams
// Decode the data using annotee. The logdog stream returned here is assumed
// to be consistent, which is why the following block of code are not
// expected to ever err out.
if body != "" {
- lds, err := streamsFromAnnotatedLog(c, body)
+ lds, err = streamsFromAnnotatedLog(c, body)
if err != nil {
build.Components = []*resp.BuildComponent{{
Type: resp.Summary,
@@ -433,18 +441,20 @@ func swarmingBuildImpl(c context.Context, linkBase, server, taskID string) (*res
URL: taskPageURL(server, taskID),
}},
}}
- } else {
- if lds.MainStream == nil || lds.MainStream.Data == nil {
- panic("no main build step stream")
- }
-
- if err := addTaskToMiloStep(c, server, sr, lds.MainStream.Data); err != nil {
- return nil, err
- }
- logdog.AddLogDogToBuild(c, swarmingURLBuilder(linkBase), lds, &build)
}
}
+ if lds != nil && lds.MainStream != nil && lds.MainStream.Data != nil {
+ s = lds.MainStream.Data
+ } else {
+ s = &miloProto.Step{}
+ }
+
+ if err := addTaskToMiloStep(c, server, sr, s); err != nil {
+ return nil, err
+ }
+ logdog.AddLogDogToBuild(c, swarmingURLBuilder(linkBase), s, &build)
+
if err := addTaskToBuild(c, server, sr, &build); err != nil {
return nil, err
}
« no previous file with comments | « milo/appengine/logdog/logDogBuild.go ('k') | milo/appengine/swarming/expectations/build-expired.json » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698