This repository was archived by the owner on Mar 31, 2026. It is now read-only.
File tree Expand file tree Collapse file tree 2 files changed +0
-10
lines changed
Expand file tree Collapse file tree 2 files changed +0
-10
lines changed Original file line number Diff line number Diff line change @@ -638,10 +638,6 @@ def _get_streamed_result_set(
638638 if self ._transaction_id is None :
639639 is_inline_begin = True
640640 self ._lock .acquire ()
641- if self ._transaction_id is not None :
642- is_inline_begin = False
643- self ._lock .release ()
644- request .transaction = TransactionSelector (id = self ._transaction_id )
645641
646642 iterator = _restart_on_unavailable (
647643 method = method ,
Original file line number Diff line number Diff line change @@ -512,9 +512,6 @@ def execute_update(
512512 if self ._transaction_id is None :
513513 is_inline_begin = True
514514 self ._lock .acquire ()
515- if self ._transaction_id is not None :
516- is_inline_begin = False
517- self ._lock .release ()
518515
519516 execute_sql_request = ExecuteSqlRequest (
520517 session = session .name ,
@@ -673,9 +670,6 @@ def batch_update(
673670 if self ._transaction_id is None :
674671 is_inline_begin = True
675672 self ._lock .acquire ()
676- if self ._transaction_id is not None :
677- is_inline_begin = False
678- self ._lock .release ()
679673
680674 execute_batch_dml_request = ExecuteBatchDmlRequest (
681675 session = session .name ,
You can’t perform that action at this time.
0 commit comments