Skip to content

Commit 2336624

Browse files
committed
review fixes
1 parent 630c188 commit 2336624

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

ydb/query/base.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -227,9 +227,9 @@ def session_id(self) -> str:
227227
@abc.abstractmethod
228228
def tx_id(self) -> Optional[str]:
229229
"""
230-
Returns a id of open transaction or None otherwise
230+
Returns an id of open transaction or None otherwise
231231
232-
:return: A id of open transaction or None otherwise
232+
:return: An id of open transaction or None otherwise
233233
"""
234234
pass
235235

ydb/query/transaction.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ def _change_state(self, target: QueryTxStateEnum) -> None:
8383
self._check_invalid_transition(target)
8484
self._state = target
8585

86-
def _check_tx_not_terminal(self) -> None:
86+
def _check_tx_ready_to_use(self) -> None:
8787
if QueryTxStateHelper.terminal(self._state):
8888
raise RuntimeError(f"Transaction is in terminal state: {self._state.value}")
8989

@@ -233,9 +233,9 @@ def session_id(self) -> str:
233233
@property
234234
def tx_id(self) -> Optional[str]:
235235
"""
236-
Returns a id of open transaction or None otherwise
236+
Returns an id of open transaction or None otherwise
237237
238-
:return: A id of open transaction or None otherwise
238+
:return: An id of open transaction or None otherwise
239239
"""
240240
return self._tx_state.tx_id
241241

@@ -371,7 +371,7 @@ def execute(
371371
) -> base.SyncResponseContextIterator:
372372

373373
self._ensure_prev_stream_finished()
374-
self._tx_state._check_tx_not_terminal()
374+
self._tx_state._check_tx_ready_to_use()
375375

376376
stream_it = self._execute_call(
377377
query=query,

0 commit comments

Comments
 (0)