Index: logdog/appengine/coordinator/endpoints/logs/get.go |
diff --git a/logdog/appengine/coordinator/endpoints/logs/get.go b/logdog/appengine/coordinator/endpoints/logs/get.go |
index 19f1e35a7e9ae6e5fafd1acc9dba9186f61dea4c..64478d023c47b8e041cd8e74a602524d3834f325 100644 |
--- a/logdog/appengine/coordinator/endpoints/logs/get.go |
+++ b/logdog/appengine/coordinator/endpoints/logs/get.go |
@@ -11,6 +11,7 @@ import ( |
log "github.com/luci/luci-go/common/logging" |
"github.com/luci/luci-go/common/proto/google" |
"github.com/luci/luci-go/common/retry" |
+ "github.com/luci/luci-go/common/retry/transient" |
"github.com/luci/luci-go/grpc/grpcutil" |
"github.com/luci/luci-go/logdog/api/endpoints/coordinator/logs/v1" |
"github.com/luci/luci-go/logdog/api/logpb" |
@@ -210,7 +211,7 @@ func getHead(c context.Context, req *logdog.GetRequest, st coordinator.Storage, |
var ierr error |
count := 0 |
- err := retry.Retry(c, retry.TransientOnly(retry.Default), func() error { |
+ err := retry.Retry(c, transient.Only(retry.Default), func() error { |
// Issue the Get request. This may return a transient error, in which case |
// we will retry. |
return st.Get(sreq, func(e *storage.Entry) bool { |
@@ -274,7 +275,7 @@ func getTail(c context.Context, st coordinator.Storage, project cfgtypes.Project |
}.Debugf(c, "Issuing Tail request.") |
var e *storage.Entry |
- err := retry.Retry(c, retry.TransientOnly(retry.Default), func() (err error) { |
+ err := retry.Retry(c, transient.Only(retry.Default), func() (err error) { |
e, err = st.Tail(project, path) |
return |
}, func(err error, delay time.Duration) { |