11package retry
22
33import (
4- "context"
5-
64 "github.com/ydb-platform/ydb-go-sdk/v3/internal/backoff"
75 "github.com/ydb-platform/ydb-go-sdk/v3/internal/operation"
86 "github.com/ydb-platform/ydb-go-sdk/v3/internal/xerrors"
@@ -16,15 +14,12 @@ func Check(err error) (
1614 deleteSession bool ,
1715) {
1816 var e xerrors.Error
19- switch {
20- case xerrors .As (err , & e ):
21- return int64 (e .Code ()), e .OperationStatus (), e .BackoffType (), e .MustDeleteSession ()
22-
23- // context errors with explicit delete session
24- case xerrors .Is (err , context .Canceled ), xerrors .Is (err , context .DeadlineExceeded ):
25- return int64 (- 1 ), operation .Finished , backoff .TypeNoBackoff , true
17+ if xerrors .As (err , & e ) {
18+ return int64 (e .Code ()),
19+ e .OperationStatus (),
20+ e .BackoffType (),
21+ e .MustDeleteSession ()
2622 }
27-
2823 return - 1 ,
2924 operation .Finished , // it's finished, not need any retry attempts
3025 backoff .TypeNoBackoff ,
@@ -33,17 +28,10 @@ func Check(err error) (
3328
3429func MustDeleteSession (err error ) bool {
3530 var e xerrors.Error
36- switch {
37- case xerrors .As (err , & e ):
31+ if xerrors .As (err , & e ) {
3832 return e .MustDeleteSession ()
39-
40- // context errors with explicit delete session
41- case xerrors .Is (err , context .Canceled ), xerrors .Is (err , context .DeadlineExceeded ):
42- return true
43-
44- default :
45- return false
4633 }
34+ return false
4735}
4836
4937func MustRetry (err error , isOperationIdempotent bool ) bool {
0 commit comments