regenerate proto changes

googleapis · harshachinta · Feb 5, 2024 · Nov 22, 2023 · Nov 22, 2023 · Dec 5, 2023
commit 7c88b09094c415578808c32511b32a3f853c5aeb
@@ -147,7 +147,9 @@ def _check_state(self):
  if self.committed is not None:
  raise ValueError("Batch already committed")
 
- def commit(self, return_commit_stats=False, request_options=None, max_commit_delay_ms=None):
+ def commit(
+ self, return_commit_stats=False, request_options=None, max_commit_delay_ms=None
+ ):
  """Commit mutations to the database.
 
  :type return_commit_stats: bool

@@ -181,7 +181,9 @@ def rollback(self):
  self.rolled_back = True
  del self._session._transaction
 
- def commit(self, return_commit_stats=False, request_options=None, max_commit_delay_ms=None):
+ def commit(
+ self, return_commit_stats=False, request_options=None, max_commit_delay_ms=None
+ ):
  """Commit mutations to the database.
 
  :type return_commit_stats: bool

diff --git a/google/cloud/spanner_v1/types/spanner.py b/google/cloud/spanner_v1/types/spanner.py
@@ -1436,13 +1436,8 @@ class CommitRequest(proto.Message):
  [CommitResponse][google.spanner.v1.CommitResponse.commit_stats].
  Default value is ``false``.
  max_commit_delay (google.protobuf.duration_pb2.Duration):
- The amount of latency this request is willing
- to incur in order to improve throughput. If this
- field is not set, Spanner assumes requests are
- relatively latency sensitive and automatically
- determines an appropriate delay time. You can
- specify a batching delay value between 0 and 500
- ms.
+
+ This field is a member of `oneof`_ ``_max_commit_delay``.
  request_options (google.cloud.spanner_v1.types.RequestOptions):
  Common options for this request.
  """
@@ -1474,6 +1469,7 @@ class CommitRequest(proto.Message):
  max_commit_delay: duration_pb2.Duration = proto.Field(
  proto.MESSAGE,
  number=8,
+ optional=True,
  message=duration_pb2.Duration,
  )
  request_options: "RequestOptions" = proto.Field(

@@ -346,7 +346,11 @@ def test_commit_w_other_error(self):
  )
 
  def _commit_helper(
- self, mutate=True, return_commit_stats=False, request_options=None, max_commit_delay_ms=None
+ self,
+ mutate=True,
+ return_commit_stats=False,
+ request_options=None,
+ max_commit_delay_ms=None,
  ):
  import datetime
  from google.cloud.spanner_v1 import CommitResponse
@@ -372,13 +376,20 @@ def _commit_helper(
  transaction.commit(
  return_commit_stats=return_commit_stats,
  request_options=request_options,
- max_commit_delay_ms=max_commit_delay_ms
+ max_commit_delay_ms=max_commit_delay_ms,
  )
 
  self.assertEqual(transaction.committed, now)
  self.assertIsNone(session._transaction)
 
- session_id, mutations, txn_id, actual_request_options, max_commit_delay, metadata = api._committed
+ (
+ session_id,
+ mutations,
+ txn_id,
+ actual_request_options,
+ max_commit_delay,
+ metadata,
+ ) = api._committed
 
  if request_options is None:
  expected_request_options = RequestOptions(
@@ -950,7 +961,7 @@ def commit(
  request.transaction_id,
  request.request_options,
  request.max_commit_delay,
-# None,
+ # None,
  metadata,
  )
  return self._commit_response