| Index: dm/appengine/mutate/schedule_execution.go
|
| diff --git a/dm/appengine/mutate/schedule_execution.go b/dm/appengine/mutate/schedule_execution.go
|
| index 614adb8d31d1a0d376c7bed24d699045989b6a31..461d99363963a0c18c68dc2576296ce0bb910a58 100644
|
| --- a/dm/appengine/mutate/schedule_execution.go
|
| +++ b/dm/appengine/mutate/schedule_execution.go
|
| @@ -8,9 +8,9 @@ import (
|
| "fmt"
|
|
|
| ds "github.com/luci/gae/service/datastore"
|
| - "github.com/luci/luci-go/common/errors"
|
| "github.com/luci/luci-go/common/logging"
|
| "github.com/luci/luci-go/common/proto/google"
|
| + "github.com/luci/luci-go/common/retry/transient"
|
| dm "github.com/luci/luci-go/dm/api/service/v1"
|
| "github.com/luci/luci-go/dm/appengine/distributor"
|
| "github.com/luci/luci-go/dm/appengine/model"
|
| @@ -86,7 +86,7 @@ func (s *ScheduleExecution) RollForward(c context.Context) (muts []tumble.Mutati
|
| }
|
| e.DistributorToken = string(distTok)
|
| if err != nil {
|
| - if errors.IsTransient(err) {
|
| + if transient.Tag.In(err) {
|
| // tumble will retry us later
|
| logging.WithError(err).Errorf(c, "got transient error in ScheduleExecution")
|
| return
|
|
|