Index: appengine/gaeauth/server/internal/authdbimpl/handlers.go |
diff --git a/appengine/gaeauth/server/internal/authdbimpl/handlers.go b/appengine/gaeauth/server/internal/authdbimpl/handlers.go |
index 404819f08c48b3836fdae6b0f053943fdfa38aa0..7a82dc5fc933ce4cd820d5fd1658ea3090608a54 100644 |
--- a/appengine/gaeauth/server/internal/authdbimpl/handlers.go |
+++ b/appengine/gaeauth/server/internal/authdbimpl/handlers.go |
@@ -17,6 +17,7 @@ import ( |
"github.com/luci/luci-go/common/errors" |
"github.com/luci/luci-go/common/logging" |
+ "github.com/luci/luci-go/common/retry/transient" |
"github.com/luci/luci-go/server/auth/service" |
"github.com/luci/luci-go/server/router" |
) |
@@ -149,7 +150,7 @@ func processPubSubRequest(c context.Context, rw http.ResponseWriter, r *http.Req |
// replyError sends HTTP 500 on transient errors, HTTP 400 on fatal ones. |
func replyError(c context.Context, rw http.ResponseWriter, err error) { |
logging.Errorf(c, "Error while processing PubSub notification - %s", err) |
- if errors.IsTransient(err) { |
+ if transient.Tag.In(err) { |
http.Error(rw, err.Error(), http.StatusInternalServerError) |
} else { |
http.Error(rw, err.Error(), http.StatusBadRequest) |