Skip to content
This repository was archived by the owner on Mar 31, 2026. It is now read-only.

Commit 739a78e

Browse files
committed
fix regular session systests
1 parent 63bac62 commit 739a78e

1 file changed

Lines changed: 8 additions & 5 deletions

File tree

google/cloud/spanner_v1/transaction.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -285,13 +285,16 @@ def commit(
285285

286286
def wrapped_method(*args, **kwargs):
287287
attempt.increment()
288+
commit_request_args = {
289+
"mutations": mutations,
290+
**common_commit_request_args,
291+
}
292+
if self._session.is_multiplexed and self._precommit_token is not None:
293+
commit_request_args["precommit_token"] = self._precommit_token
294+
288295
commit_method = functools.partial(
289296
api.commit,
290-
request=CommitRequest(
291-
mutations=mutations,
292-
precommit_token=self._precommit_token,
293-
**common_commit_request_args,
294-
),
297+
request=CommitRequest(**commit_request_args),
295298
metadata=database.metadata_with_request_id(
296299
nth_request,
297300
attempt.value,

0 commit comments

Comments
 (0)