Merge pull request #1563 from ydb-platform/issue_1550_fix

Avoid retrying requests finished with 'UNAUTHORIZED' errors

Author: asmyasnikov

CHANGELOG.md

@@ -1,11 +1,12 @@
+* Avoid retrying requests finished with 'UNAUTHORIZED' errors
+
 ## v3.92.4
 * Fixed connections pool leak on closing
 
 ## v3.92.3
 * Fixed error with incompleted data returen from transaction.ReadQueryResult method
 * Added option `query/WithResponsePartLimitSizeBytes(...)` for queries with query service
 
-
 ## v3.92.2
 * Added `table/options.WithShardNodesInfo()` experimental option to get shard nodeId for describe table call
 

internal/pool/pool.go

@@ -7,6 +7,7 @@ import (
 	"time"
 
 	"github.com/jonboulle/clockwork"
+	"github.com/ydb-platform/ydb-go-genproto/protos/Ydb"
 
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/endpoint"
 	"github.com/ydb-platform/ydb-go-sdk/v3/internal/stack"
@@ -339,7 +340,14 @@ func (p *Pool[PT, T]) try(ctx context.Context, f func(ctx context.Context, item
 	item, err := p.getItem(ctx)
 	if err != nil {
 		if xerrors.IsYdb(err) {
-			return xerrors.WithStackTrace(xerrors.Retryable(err))
+			switch {
+			case xerrors.IsOperationError(err, Ydb.StatusIds_UNAUTHORIZED):
+				// https://github.com/ydb-platform/ydb-go-sdk/issues/1550
+				// Avoid retrying UNAUTHORIZED errors.
+				return xerrors.WithStackTrace(xerrors.Unretryable(err))
+			default:
+				return xerrors.WithStackTrace(xerrors.Retryable(err))
+			}
 		}
 
 		return xerrors.WithStackTrace(err)