pubsub/azpubsub: Ensure 401s are not retryable (google#3379)

stanhu · Jan 26, 2024 · 4e3dfbe · 4e3dfbe
1 parent 1c8e1d8
commit 4e3dfbe
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pubsub/azuresb/azuresb.go b/pubsub/azuresb/azuresb.go
@@ -566,6 +566,9 @@ func errorCode(err error) (gcerrors.ErrorCode, bool) {
 	if strings.Contains(err.Error(), "status code 404") {
 		return gcerrors.NotFound, false
 	}
+	if strings.Contains(err.Error(), "status code 401") {
+		return gcerrors.PermissionDenied, false
+	}
 	var cond amqp.ErrCond
 	var aderr *amqp.LinkError
 	var aerr *amqp.Error