Index: logdog/server/cmd/logdog_archivist/main.go |
diff --git a/logdog/server/cmd/logdog_archivist/main.go b/logdog/server/cmd/logdog_archivist/main.go |
index 93e469480b507e05029390052dd4c590415a4aeb..0e246cff0d4222a4f71244f99f2d80434c62334f 100644 |
--- a/logdog/server/cmd/logdog_archivist/main.go |
+++ b/logdog/server/cmd/logdog_archivist/main.go |
@@ -14,6 +14,7 @@ import ( |
gcps "github.com/luci/luci-go/common/gcloud/pubsub" |
log "github.com/luci/luci-go/common/logging" |
"github.com/luci/luci-go/common/retry" |
+ "github.com/luci/luci-go/common/retry/transient" |
"github.com/luci/luci-go/common/tsmon/distribution" |
"github.com/luci/luci-go/common/tsmon/field" |
"github.com/luci/luci-go/common/tsmon/metric" |
@@ -145,7 +146,7 @@ func (a *application) runArchivist(c context.Context) error { |
} |
} |
- err = retry.Retry(c, retry.TransientOnly(retryForever), func() error { |
+ err = retry.Retry(c, transient.Only(retryForever), func() error { |
return grpcutil.WrapIfTransient(sub.Receive(c, func(c context.Context, msg *pubsub.Message) { |
c = log.SetFields(c, log.Fields{ |
"messageID": msg.ID, |