File tree Expand file tree Collapse file tree 3 files changed +3
-4
lines changed
Expand file tree Collapse file tree 3 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -166,7 +166,7 @@ def commit(
166166 request_options = None ,
167167 max_commit_delay = None ,
168168 exclude_txn_from_change_streams = False ,
169- ** kwargs
169+ ** kwargs ,
170170 ):
171171 """Commit mutations to the database.
172172
Original file line number Diff line number Diff line change 1515"""Wrapper for Cloud Spanner Session objects."""
1616
1717from functools import total_ordering
18- import random
1918import time
2019from datetime import datetime
2120
2221from google .api_core .exceptions import Aborted
2322from google .api_core .exceptions import GoogleAPICallError
2423from google .api_core .exceptions import NotFound
2524from google .api_core .gapic_v1 import method
26- from google .rpc .error_details_pb2 import RetryInfo
25+ from google .cloud .spanner_v1 ._helpers import _delay_until_retry
26+ from google .cloud .spanner_v1 ._helpers import _get_retry_delay
2727
2828from google .cloud .spanner_v1 import ExecuteSqlRequest
2929from google .cloud .spanner_v1 import CreateSessionRequest
Original file line number Diff line number Diff line change @@ -703,7 +703,6 @@ def commit(
703703 from google .api_core .exceptions import Aborted
704704
705705 max_commit_delay = None
706- print ("Spanner commit called" )
707706 if type (request ).pb (request ).HasField ("max_commit_delay" ):
708707 max_commit_delay = request .max_commit_delay
709708
You can’t perform that action at this time.
0 commit comments