Skip to content

Commit 630c188

Browse files
committed
fixes
1 parent 2d8a2ff commit 630c188

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

ydb/query/session.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ def wrapper_create_session(
105105
rpc_state: RpcState,
106106
response_pb: _apis.ydb_query.CreateSessionResponse,
107107
session_state: QuerySessionState,
108-
session: "BaseQuerySession"
108+
session: "BaseQuerySession",
109109
) -> "BaseQuerySession":
110110
message = _ydb_query.CreateSessionResponse.from_proto(response_pb)
111111
issues._process_response(message.status)
@@ -117,7 +117,7 @@ def wrapper_delete_session(
117117
rpc_state: RpcState,
118118
response_pb: _apis.ydb_query.DeleteSessionResponse,
119119
session_state: QuerySessionState,
120-
session: "BaseQuerySession"
120+
session: "BaseQuerySession",
121121
) -> "BaseQuerySession":
122122
message = _ydb_query.DeleteSessionResponse.from_proto(response_pb)
123123
issues._process_response(message.status)

ydb/query/transaction.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,9 @@ def terminal(cls, state: QueryTxStateEnum) -> bool:
5252

5353
def reset_tx_id_handler(func):
5454
@functools.wraps(func)
55-
def decorator(rpc_state, response_pb, session_state: base.IQuerySessionState, tx_state: QueryTxState, *args, **kwargs):
55+
def decorator(
56+
rpc_state, response_pb, session_state: base.IQuerySessionState, tx_state: QueryTxState, *args, **kwargs
57+
):
5658
try:
5759
return func(rpc_state, response_pb, session_state, tx_state, *args, **kwargs)
5860
except issues.Error:

0 commit comments

Comments
 (0)