diff --git a/internal/dbtx/tx.go b/internal/dbtx/tx.go
index 2654ab5..c4cd332 100644
--- a/internal/dbtx/tx.go
+++ b/internal/dbtx/tx.go
@@ -3,6 +3,7 @@ package dbtx
 import (
 	"context"
 	"database/sql"
+	"errors"
 )
 
 func Run[T any](ctx context.Context, sqlDB *sql.DB, repo T, withTx func(*sql.Tx) T, fn func(context.Context, T) error) error {
@@ -17,7 +18,9 @@ func Run[T any](ctx context.Context, sqlDB *sql.DB, repo T, withTx func(*sql.Tx)
 
 	txRepo := withTx(tx)
 	if err := fn(ctx, txRepo); err != nil {
-		_ = tx.Rollback()
+		if rollbackErr := tx.Rollback(); rollbackErr != nil {
+			return errors.Join(err, rollbackErr)
+		}
 		return err
 	}