From 58a2d3cd09ccae6d9e88d428685a0b09371dc81b Mon Sep 17 00:00:00 2001
From: Gani Georgiev <gani.georgiev@gmail.com>
Date: Sun, 3 Dec 2023 20:54:48 +0200
Subject: [PATCH] added the failed dao query to the error message

---
 daos/base_retry.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/daos/base_retry.go b/daos/base_retry.go
index 05905c07..f74b4c13 100644
--- a/daos/base_retry.go
+++ b/daos/base_retry.go
@@ -2,6 +2,7 @@ package daos
 
 import (
 	"context"
+	"fmt"
 	"strings"
 	"time"
 
@@ -23,9 +24,14 @@ func execLockRetry(timeout time.Duration, maxRetries int) dbx.ExecHookFunc {
 			q.WithContext(cancelCtx)
 		}
 
-		return baseLockRetry(func(attempt int) error {
+		execErr := baseLockRetry(func(attempt int) error {
 			return op()
 		}, maxRetries)
+		if execErr != nil {
+			return fmt.Errorf("%w; failed query: %s", execErr, q.SQL())
+		}
+
+		return nil
 	}
 }