pgsql: fix RunInTxContext when retry exceed (#20)

acoshift · Jan 22, 2021 · eb94dfc · eb94dfc
1 parent 1f776f3
commit eb94dfc
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/tx.go b/tx.go
@@ -73,8 +73,9 @@ func RunInTxContext(ctx context.Context, db BeginTxer, opts *TxOptions, fn func(
 		return tx.Commit()
 	}
 
+	var err error
 	for i := 0; i < option.MaxAttempts; i++ {
-		err := f()
+		err = f()
 		if err == nil || errors.Is(err, ErrAbortTx) {
 			return nil
 		}
@@ -84,5 +85,5 @@ func RunInTxContext(ctx context.Context, db BeginTxer, opts *TxOptions, fn func(
 		}
 	}
 
-	return nil
+	return err
 }