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 ec7274f commit 6b07d63Copy full SHA for 6b07d63
ydb/query/base.py
@@ -192,11 +192,11 @@ def create_execute_query_request(
192
return req.to_proto()
193
194
195
-def wrap_execute_query_response(rpc_state, response_pb, tx, commit_tx=False):
+def wrap_execute_query_response(rpc_state, response_pb, tx=None, commit_tx=False):
196
issues._process_response(response_pb)
197
- if response_pb.tx_meta and not tx.tx_id:
+ if tx and response_pb.tx_meta and not tx.tx_id:
198
tx._handle_tx_meta(response_pb.tx_meta)
199
- if commit_tx:
+ if tx and commit_tx:
200
tx._move_to_commited()
201
return convert.ResultSet.from_message(response_pb.result_set)
202
0 commit comments