We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4514e46 commit 2c0380eCopy full SHA for 2c0380e
internal/query/session.go
@@ -181,8 +181,9 @@ func (s *Session) Query(
181
182
func (s *Session) setStatusFromError(err error) {
183
switch {
184
- case xerrors.IsTransportError(err) ||
185
- xerrors.IsOperationError(err, Ydb.StatusIds_SESSION_BUSY, Ydb.StatusIds_BAD_SESSION):
+ case xerrors.IsTransportError(err):
+ s.SetStatus(session.StatusError)
186
+ case xerrors.IsOperationError(err, Ydb.StatusIds_SESSION_BUSY, Ydb.StatusIds_BAD_SESSION):
187
s.SetStatus(session.StatusError)
188
case xerrors.IsOperationError(err, Ydb.StatusIds_BAD_SESSION):
189
s.SetStatus(session.StatusClosed)
0 commit comments