docs: A comment for field partner_model_tuning_spec in message .google.cloud.aiplatform.v1beta1.TuningJob is changed (#4538)

* chore: Update gapic-generator-python to v1.19.1 PiperOrigin-RevId: 684571179 Source-Link: googleapis/googleapis@fbdc238 Source-Link: googleapis/googleapis-gen@3a2cdcf Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiM2EyY2RjZmI4MGMyZDBmNWVjMGNjNjYzYzJiYWIwYTk0ODYyMjlkMCJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * docs: A comment for field `partner_model_tuning_spec` in message `.google.cloud.aiplatform.v1beta1.TuningJob` is changed PiperOrigin-RevId: 684636851 Source-Link: googleapis/googleapis@de509e3 Source-Link: googleapis/googleapis-gen@5ec9807 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNWVjOTgwN2ZhMjI1ZGI5MWM2YzZkMzM1MzM4YTVmMGZiMzZlMzRiOSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>

Author: gcf-owl-bot[bot]

google/cloud/aiplatform_v1/__init__.py

@@ -103,6 +103,7 @@
 from .types.content import GroundingSupport
 from .types.content import LogprobsResult
 from .types.content import Part
+from .types.content import RetrievalMetadata
 from .types.content import SafetyRating
 from .types.content import SafetySetting
 from .types.content import SearchEntryPoint
@@ -863,6 +864,7 @@
 from .types.tensorboard_service import WriteTensorboardRunDataRequest
 from .types.tensorboard_service import WriteTensorboardRunDataResponse
 from .types.tensorboard_time_series import TensorboardTimeSeries
+from .types.tool import DynamicRetrievalConfig
 from .types.tool import FunctionCall
 from .types.tool import FunctionCallingConfig
 from .types.tool import FunctionDeclaration
@@ -1162,6 +1164,7 @@
  "DirectRawPredictResponse",
  "DiskSpec",
  "DoubleArray",
+ "DynamicRetrievalConfig",
  "EncryptionSpec",
  "Endpoint",
  "EndpointServiceClient",
@@ -1596,6 +1599,7 @@
  "ResumeModelDeploymentMonitoringJobRequest",
  "ResumeScheduleRequest",
  "Retrieval",
+ "RetrievalMetadata",
  "RougeInput",
  "RougeInstance",
  "RougeMetricValue",

google/cloud/aiplatform_v1/services/dataset_service/async_client.py

@@ -2663,11 +2663,7 @@ async def list_operations(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.list_operations,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.list_operations]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -2720,11 +2716,7 @@ async def get_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.get_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.get_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -2781,11 +2773,7 @@ async def delete_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.delete_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.delete_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -2838,11 +2826,7 @@ async def cancel_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.cancel_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.cancel_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -2898,11 +2882,7 @@ async def wait_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.wait_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.wait_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3021,11 +3001,7 @@ async def set_iam_policy(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.set_iam_policy,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.set_iam_policy]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3145,11 +3121,7 @@ async def get_iam_policy(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.get_iam_policy,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.get_iam_policy]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3207,11 +3179,9 @@ async def test_iam_permissions(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.test_iam_permissions,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[
+ self._client._transport.test_iam_permissions
+ ]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3264,11 +3234,7 @@ async def get_location(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.get_location,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.get_location]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3321,11 +3287,7 @@ async def list_locations(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method_async.wrap_method(
- self._client._transport.list_locations,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self.transport._wrapped_methods[self._client._transport.list_locations]
 
  # Certain fields should be provided within the metadata header;
  # add these here.

google/cloud/aiplatform_v1/services/dataset_service/client.py

@@ -3150,11 +3150,7 @@ def list_operations(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.list_operations,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.list_operations]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3207,11 +3203,7 @@ def get_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.get_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.get_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3268,11 +3260,7 @@ def delete_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.delete_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.delete_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3325,11 +3313,7 @@ def cancel_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.cancel_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.cancel_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3385,11 +3369,7 @@ def wait_operation(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.wait_operation,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.wait_operation]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3508,11 +3488,7 @@ def set_iam_policy(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.set_iam_policy,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.set_iam_policy]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3632,11 +3608,7 @@ def get_iam_policy(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.get_iam_policy,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.get_iam_policy]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3694,11 +3666,7 @@ def test_iam_permissions(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.test_iam_permissions,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.test_iam_permissions]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3751,11 +3719,7 @@ def get_location(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.get_location,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.get_location]
 
  # Certain fields should be provided within the metadata header;
  # add these here.
@@ -3808,11 +3772,7 @@ def list_locations(
 
  # Wrap the RPC method; this adds retry and timeout information,
  # and friendly error handling.
- rpc = gapic_v1.method.wrap_method(
- self._transport.list_locations,
- default_timeout=None,
- client_info=DEFAULT_CLIENT_INFO,
- )
+ rpc = self._transport._wrapped_methods[self._transport.list_locations]
 
  # Certain fields should be provided within the metadata header;
  # add these here.

google/cloud/aiplatform_v1/services/dataset_service/transports/README.rst

@@ -0,0 +1,9 @@
+
+transport inheritance structure
+_______________________________
+
+`DatasetServiceTransport` is the ABC for all transports.
+- public child `DatasetServiceGrpcTransport` for sync gRPC transport (defined in `grpc.py`).
+- public child `DatasetServiceGrpcAsyncIOTransport` for async gRPC transport (defined in `grpc_asyncio.py`).
+- private child `_BaseDatasetServiceRestTransport` for base REST transport with inner classes `_BaseMETHOD` (defined in `rest_base.py`).
+- public child `DatasetServiceRestTransport` for sync REST transport with inner classes `METHOD` derived from the parent's corresponding `_BaseMETHOD` classes (defined in `rest.py`).

google/cloud/aiplatform_v1/services/dataset_service/transports/base.py

@@ -234,6 +234,56 @@ def _prep_wrapped_messages(self, client_info):
  default_timeout=None,
  client_info=client_info,
  ),
+ self.get_location: gapic_v1.method.wrap_method(
+ self.get_location,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.list_locations: gapic_v1.method.wrap_method(
+ self.list_locations,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.get_iam_policy: gapic_v1.method.wrap_method(
+ self.get_iam_policy,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.set_iam_policy: gapic_v1.method.wrap_method(
+ self.set_iam_policy,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.test_iam_permissions: gapic_v1.method.wrap_method(
+ self.test_iam_permissions,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.cancel_operation: gapic_v1.method.wrap_method(
+ self.cancel_operation,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.delete_operation: gapic_v1.method.wrap_method(
+ self.delete_operation,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.get_operation: gapic_v1.method.wrap_method(
+ self.get_operation,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.list_operations: gapic_v1.method.wrap_method(
+ self.list_operations,
+ default_timeout=None,
+ client_info=client_info,
+ ),
+ self.wait_operation: gapic_v1.method.wrap_method(
+ self.wait_operation,
+ default_timeout=None,
+ client_info=client_info,
+ ),
  }
 
  def close(self):

google/cloud/aiplatform_v1/services/dataset_service/transports/grpc.py

@@ -830,7 +830,7 @@ def wait_operation(
  # the request.
  # gRPC handles serialization and deserialization, so we just need
  # to pass in the functions for each.
- if "delete_operation" not in self._stubs:
+ if "wait_operation" not in self._stubs:
  self._stubs["wait_operation"] = self.grpc_channel.unary_unary(
  "/google.longrunning.Operations/WaitOperation",
  request_serializer=operations_pb2.WaitOperationRequest.SerializeToString,