* Wrapped retry operation errors with errors.WithStackTrace(err)

Author: asmyasnikov

CHANGELOG.md

@@ -3,6 +3,7 @@
 * Removed `trace.Driver.OnClusterUpdate` event
 * Fixed bug with unexpected changing of local datacenter flag in endpoint
 * Refactored errors wrapping (stackedError are not ydb error now, checking `errors.IsYdb(err)` with `errors.As` now)
+* Wrapped retry operation errors with `errors.WithStackTrace(err)`
 
 ## v3.16.9
 * Refactored internal operation and transport errors

internal/table/retry.go

@@ -62,7 +62,7 @@ func doTx(ctx context.Context, c SessionProvider, op table.TxOperation, opts tab
 			err = op(ctx, tx)
 
 			if err != nil {
-				return err
+				return errors.WithStackTrace(err)
 			}
 
 			_, err = tx.CommitTx(ctx, opts.TxCommitOptions...)
@@ -96,7 +96,13 @@ func do(ctx context.Context, c SessionProvider, op table.Operation, opts table.O
 				attempts++
 			}()
 
-			return op(ctx, s)
+			err = op(ctx, s)
+
+			if err != nil {
+				return errors.WithStackTrace(err)
+			}
+
+			return nil
 		},
 	)
 }
@@ -236,11 +242,11 @@ func retryBackoff(
 			}
 
 			if !m.MustRetry(isOperationIdempotent) {
-				return
+				return errors.WithStackTrace(err)
 			}
 
 			if retry.Wait(ctx, fastBackoff, slowBackoff, m, i) != nil {
-				return
+				return errors.WithStackTrace(err)
 			}
 
 			code = m.StatusCode()

retry/retry.go

@@ -152,11 +152,11 @@ func Retry(ctx context.Context, op retryOperation, opts ...retryOption) (err err
 			}
 
 			if !m.MustRetry(h.idempotent) {
-				return
+				return errors.WithStackTrace(err)
 			}
 
 			if e := Wait(ctx, h.fastBackoff, h.slowBackoff, m, i); e != nil {
-				return
+				return errors.WithStackTrace(err)
 			}
 
 			code = m.StatusCode()