We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bf926fa commit 5582a20Copy full SHA for 5582a20
database/yugabytedb/yugabytedb.go
@@ -421,16 +421,20 @@ func (c *YugabyteDB) doTxWithRetry(
421
//nolint:errcheck
422
defer tx.Rollback()
423
424
- if err := fn(tx); err != nil && !errIsRetryable(err) {
+ if err := fn(tx); err != nil {
425
+ if errIsRetryable(err) {
426
+ return err
427
+ }
428
+
429
return backoff.Permanent(err)
- } else if err != nil {
- return err
430
}
431
- if err := tx.Commit(); err != nil && !errIsRetryable(err) {
432
+ if err := tx.Commit(); err != nil {
433
434
435
436
437
438
439
440
return nil
0 commit comments