| Index: scheduler/appengine/task/buildbucket/buildbucket.go
|
| diff --git a/scheduler/appengine/task/buildbucket/buildbucket.go b/scheduler/appengine/task/buildbucket/buildbucket.go
|
| index 48e7a731fa5d065c045ca9f359c9ca40207f1655..a25727f54f53c4383ea2a1ece66303be601df771 100644
|
| --- a/scheduler/appengine/task/buildbucket/buildbucket.go
|
| +++ b/scheduler/appengine/task/buildbucket/buildbucket.go
|
| @@ -18,6 +18,7 @@ import (
|
| "github.com/luci/gae/service/info"
|
| "github.com/luci/luci-go/common/api/buildbucket/buildbucket/v1"
|
| "github.com/luci/luci-go/common/errors"
|
| + "github.com/luci/luci-go/common/retry/transient"
|
| "github.com/luci/luci-go/scheduler/appengine/messages"
|
| "github.com/luci/luci-go/scheduler/appengine/task"
|
| "github.com/luci/luci-go/scheduler/appengine/task/utils"
|
| @@ -296,7 +297,7 @@ func (m TaskManager) checkBuildStatus(c context.Context, ctl task.Controller) er
|
| // still running LaunchTask when saving the invocation, it will only make the
|
| // matters worse.
|
| case status == task.StatusStarting:
|
| - return errors.WrapTransient(errors.New("invocation is still starting, try again later"))
|
| + return errors.New("invocation is still starting, try again later", transient.Tag)
|
| case status != task.StatusRunning:
|
| return fmt.Errorf("unexpected invocation status %q, expecting %q", status, task.StatusRunning)
|
| }
|
| @@ -317,7 +318,7 @@ func (m TaskManager) checkBuildStatus(c context.Context, ctl task.Controller) er
|
| if err != nil {
|
| ctl.DebugLog("Failed to fetch buildbucket build - %s", err)
|
| err = utils.WrapAPIError(err)
|
| - if !errors.IsTransient(err) {
|
| + if !transient.Tag.In(err) {
|
| ctl.State().Status = task.StatusFailed
|
| }
|
| return err
|
|
|