Index: tokenserver/appengine/impl/utils/policy/policy.go |
diff --git a/tokenserver/appengine/impl/utils/policy/policy.go b/tokenserver/appengine/impl/utils/policy/policy.go |
index 3f936b928270ccfad61daf98809c6da97c75bba2..e8b7d217ae518d710e6081d00f4f2db973331fc6 100644 |
--- a/tokenserver/appengine/impl/utils/policy/policy.go |
+++ b/tokenserver/appengine/impl/utils/policy/policy.go |
@@ -123,7 +123,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) { |
err = errors.New("no configs fetched by the callback") |
} |
if err != nil { |
- return "", errors.Annotate(err).Reason("failed to fetch policy configs").Err() |
+ return "", errors.Annotate(err, "failed to fetch policy configs").Err() |
} |
rev = fetcher.Revision() |
@@ -132,7 +132,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) { |
// SHA256 digest). |
cfgBlob, err := serializeBundle(bundle) |
if err != nil { |
- return "", errors.Annotate(err).Reason("failed to serialize the configs").Err() |
+ return "", errors.Annotate(err, "failed to serialize the configs").Err() |
} |
digest := sha256.Sum256(cfgBlob) |
digestHex := hex.EncodeToString(digest[:]) |
@@ -141,7 +141,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) { |
// Do we have it already? |
existingHdr, err := getImportedPolicyHeader(c, p.Name) |
if err != nil { |
- return "", errors.Annotate(err).Reason("failed to grab ImportedPolicyHeader").Err() |
+ return "", errors.Annotate(err, "failed to grab ImportedPolicyHeader").Err() |
} |
if existingHdr != nil && digestHex == existingHdr.SHA256 { |
logging.Infof( |
@@ -160,9 +160,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) { |
v := validation.Context{Logger: logging.Get(c)} |
p.Validate(bundle, &v) |
if err := v.Finalize(); err != nil { |
- return "", errors.Annotate(err). |
- Reason("configs at rev %(rev)s are invalid"). |
- D("rev", rev).Err() |
+ return "", errors.Annotate(err, "configs at rev %s are invalid", rev).Err() |
} |
} |
@@ -173,7 +171,7 @@ func (p *Policy) ImportConfigs(c context.Context) (rev string, err error) { |
err = errors.New("wrong revision in result of Prepare callback") |
} |
if err != nil { |
- return "", errors.Annotate(err).Reason("failed to convert configs into a queryable form").Err() |
+ return "", errors.Annotate(err, "failed to convert configs into a queryable form").Err() |
} |
logging.Infof(c, "Storing new configs") |
@@ -210,7 +208,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy |
hdr, err := getImportedPolicyHeader(c, p.Name) |
switch { |
case err != nil: |
- err = errors.Annotate(err).Reason("failed to fetch importedPolicyHeader entity").Err() |
+ err = errors.Annotate(err, "failed to fetch importedPolicyHeader entity").Err() |
return |
case hdr == nil: |
err = ErrNoPolicy |
@@ -231,7 +229,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy |
body, err := getImportedPolicyBody(c, p.Name) |
switch { |
case err != nil: |
- err = errors.Annotate(err).Reason("failed to fetch importedPolicyBody entity").Err() |
+ err = errors.Annotate(err, "failed to fetch importedPolicyBody entity").Err() |
return |
case body == nil: // this is rare, the body shouldn't disappear |
logging.Errorf(c, "The policy body is unexpectedly gone") |
@@ -249,7 +247,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy |
logging.Infof(c, "Using configs at rev %s", body.Revision) |
configs, unknown, err := deserializeBundle(body.Data) |
if err != nil { |
- err = errors.Annotate(err).Reason("failed to deserialize cached configs").Err() |
+ err = errors.Annotate(err, "failed to deserialize cached configs").Err() |
return |
} |
if len(unknown) != 0 { |
@@ -261,7 +259,7 @@ func (p *Policy) grabQueryable(c context.Context, prev lazyslot.Value) (val lazy |
} |
queryable, err := p.Prepare(configs, body.Revision) |
if err != nil { |
- err = errors.Annotate(err).Reason("failed to process cached configs").Err() |
+ err = errors.Annotate(err, "failed to process cached configs").Err() |
return |
} |