Skip to content

Commit 793b547

Browse files
committed
exclude error wrapping from retry operation
1 parent bb25af6 commit 793b547

File tree

3 files changed

+4
-10
lines changed

3 files changed

+4
-10
lines changed

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
## 3.11.1
2+
* Excluded error wrapping from retry operations
3+
14
## 3.11.0
25
* Added `ydb.WithTLSSInsecureSkipVerify()` option
36
* Added `trace.Table.OnPoolStateChange` event

internal/meta/version.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
package meta
22

33
const (
4-
Version = "ydb-go-sdk/3.11.0"
4+
Version = "ydb-go-sdk/3.11.1"
55
)

internal/table/retry.go

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -90,18 +90,12 @@ func doTx(ctx context.Context, c SessionProvider, op table.TxOperation, opts ...
9090
options.options.Idempotent,
9191
func(ctx context.Context, s table.Session) (err error) {
9292
tx, err := s.BeginTransaction(ctx, options.options.TxSettings)
93-
if err != nil {
94-
err = errors.Errorf(0, "begin transaction failed: %w", err)
95-
}
9693
defer func() {
9794
if err != nil {
9895
_ = tx.Rollback(ctx)
9996
}
10097
}()
10198
err = op(ctx, tx)
102-
if err != nil {
103-
err = errors.Errorf(0, "operation failed: %w", err)
104-
}
10599
if attempts > 0 {
106100
onIntermediate(err)
107101
}
@@ -137,9 +131,6 @@ func do(ctx context.Context, c SessionProvider, op table.Operation, opts ...retr
137131
options.options.Idempotent,
138132
func(ctx context.Context, s table.Session) error {
139133
err = op(ctx, s)
140-
if err != nil {
141-
err = errors.Errorf(0, "operation failed: %w", err)
142-
}
143134
if attempts > 0 {
144135
onIntermediate(err)
145136
}

0 commit comments

Comments
 (0)