| Index: dm/appengine/mutate/add_deps.go
|
| diff --git a/dm/appengine/mutate/add_deps.go b/dm/appengine/mutate/add_deps.go
|
| index 219688125ce6aea663b03faaebbb87b89d4f2f94..0645ffa03e3d28b568ec25c095f140eec7fcb669 100644
|
| --- a/dm/appengine/mutate/add_deps.go
|
| +++ b/dm/appengine/mutate/add_deps.go
|
| @@ -7,6 +7,7 @@ package mutate
|
| import (
|
| ds "github.com/luci/gae/service/datastore"
|
| "github.com/luci/luci-go/common/data/bit_field"
|
| + "github.com/luci/luci-go/common/errors"
|
| "github.com/luci/luci-go/common/logging"
|
| "github.com/luci/luci-go/dm/api/service/v1"
|
| "github.com/luci/luci-go/dm/appengine/model"
|
| @@ -50,7 +51,8 @@ func (a *AddDeps) RollForward(c context.Context) (muts []tumble.Mutation, err er
|
| }
|
|
|
| fwdDeps, err := filterExisting(c, model.FwdDepsFromList(c, a.Auth.Id.AttemptID(), a.Deps))
|
| - err = grpcutil.Annotate(err, codes.Internal).Reason("while filtering deps").Err()
|
| + err = errors.Annotate(err).Tag(grpcutil.Tag.With(codes.Internal)).
|
| + Reason("while filtering deps").Err()
|
| if err != nil || len(fwdDeps) == 0 {
|
| return
|
| }
|
| @@ -64,7 +66,8 @@ func (a *AddDeps) RollForward(c context.Context) (muts []tumble.Mutation, err er
|
| }
|
|
|
| if err = ds.Put(c, fwdDeps, atmpt, ex); err != nil {
|
| - err = grpcutil.Annotate(err, codes.Internal).Reason("putting stuff").Err()
|
| + err = errors.Annotate(err).Tag(grpcutil.Tag.With(codes.Internal)).
|
| + Reason("putting stuff").Err()
|
| return
|
| }
|
|
|
|
|