diff --git a/internal/pkg/lock/mutex.go b/internal/pkg/lock/mutex.go index 1eb23d4..9df58f2 100644 --- a/internal/pkg/lock/mutex.go +++ b/internal/pkg/lock/mutex.go @@ -2,6 +2,7 @@ package lock import ( "context" + "fmt" "github.com/redis/go-redis/v9" "time" ) @@ -21,7 +22,7 @@ func (c *Mutex) Lock(ctx context.Context, resource string, callback func(ctx con l := c.locker.GetLock(resource) if err := l.Lock(ctx); err != nil { - return err + return fmt.Errorf("lock failed: %w", err) } defer func() { _ = l.Unlock(ctx)