skip wrapping sql.ErrNoRows

choigawoon · Dec 4, 2023 · 14a2fd6 · 14a2fd6
1 parent cdfc1f7
commit 14a2fd6
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/daos/base_retry.go b/daos/base_retry.go
@@ -2,6 +2,8 @@ package daos
 
 import (
 	"context"
+	"database/sql"
+	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -27,11 +29,11 @@ func execLockRetry(timeout time.Duration, maxRetries int) dbx.ExecHookFunc {
 		execErr := baseLockRetry(func(attempt int) error {
 			return op()
 		}, maxRetries)
-		if execErr != nil {
-			return fmt.Errorf("%w; failed query: %s", execErr, q.SQL())
+		if execErr != nil && !errors.Is(execErr, sql.ErrNoRows) {
+			execErr = fmt.Errorf("%w; failed query: %s", execErr, q.SQL())
 		}
 
-		return nil
+		return execErr
 	}
 }