Skip to content

Commit 2062b7e

Browse files
committed
Retry remove directory on retriable error
1 parent d64c4a2 commit 2062b7e

File tree

3 files changed

+9
-2
lines changed

3 files changed

+9
-2
lines changed

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
## 3.7.2
2+
* Retry remove directory in sugar.RemoveRecursive for retriable error
3+
14
## 3.7.1
25
* Fixed panic on `result.Reset(nil)`
36

internal/meta/version.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
package meta
22

33
const (
4-
Version = "ydb-go-sdk/3.7.1"
4+
Version = "ydb-go-sdk/3.7.2"
55
)

sugar/sugar.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@ import (
88

99
ydb "github.com/ydb-platform/ydb-go-sdk/v3"
1010
"github.com/ydb-platform/ydb-go-sdk/v3/internal/errors"
11+
"github.com/ydb-platform/ydb-go-sdk/v3/retry"
1112
"github.com/ydb-platform/ydb-go-sdk/v3/scheme"
1213
"github.com/ydb-platform/ydb-go-sdk/v3/table"
1314
)
@@ -84,7 +85,10 @@ func RemoveRecursive(ctx context.Context, db ydb.Connection, pathToRemove string
8485
if err = list(i+1, pt); err != nil {
8586
return err
8687
}
87-
if err = db.Scheme().RemoveDirectory(ctx, pt); err != nil {
88+
err = retry.Retry(ctx, true, func(ctx context.Context) (err error) {
89+
return db.Scheme().RemoveDirectory(ctx, pt)
90+
})
91+
if err != nil {
8892
return err
8993
}
9094

0 commit comments

Comments
 (0)