Skip to content

Commit 67faec4

Browse files
committed
change tx commit lifecycle
1 parent 49e622e commit 67faec4

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

ydb/query/base.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -187,8 +187,9 @@ def wrap_execute_query_response(
187187
settings: Optional[QueryClientSettings] = None,
188188
) -> convert.ResultSet:
189189
issues._process_response(response_pb)
190-
if tx and response_pb.tx_meta and not tx.tx_id:
191-
tx._move_to_beginned(response_pb.tx_meta.id)
192190
if tx and commit_tx:
193191
tx._move_to_commited()
192+
elif tx and response_pb.tx_meta and not tx.tx_id:
193+
tx._move_to_beginned(response_pb.tx_meta.id)
194+
194195
return convert.ResultSet.from_message(response_pb.result_set, settings)

0 commit comments

Comments
 (0)