chore: Update gapic-generator-python to 1.24.1 (#924)

gcf-owl-bot[bot] · web-flow · commit 31d2d02fe766 · 2025-04-21T15:36:22.000-07:00
* chore: Update gapic-generator-python to 1.24.0 PiperOrigin-RevId: 747419463 Source-Link: googleapis/googleapis@340579b Source-Link: googleapis/googleapis-gen@e8997ec Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZTg5OTdlYzUxMzZlY2I2ZWQ5YTk2OWE0YzJmMTNiM2FiNmExN2MxMiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: increased the number of partitions can be written in a single request docs: updated the number of partitions (from 100 to 900) can be inserted, updated and deleted in a single request BREAKING CHANGE: remove `location` from http annotations in all of the service requests PiperOrigin-RevId: 747473743 Source-Link: googleapis/googleapis@1c153ad Source-Link: googleapis/googleapis-gen@b5aa0e8 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjVhYTBlODkxZjQ1N2IxYzVjZTc1YjEyMGQxYjY1Yzg3Mzg3NzZiNSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * chore: Update gapic-generator-python to 1.24.1 PiperOrigin-RevId: 748739072 Source-Link: googleapis/googleapis@b947e52 Source-Link: googleapis/googleapis-gen@8c5821a Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOGM1ODIxYWE2NWE5MjFkNTliM2Y3NjUzZDZmMzdjOWM2NzQxMGMyZiJ9 * 🦉 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>
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_read/transports/grpc.py
@@ -69,12 +69,11 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
                 f"Sending request for {client_call_details.method}",
                 extra={
                     "serviceName": "google.cloud.bigquery.storage.v1.BigQueryRead",
-                    "rpcName": client_call_details.method,
+                    "rpcName": str(client_call_details.method),
                     "request": grpc_request,
                     "metadata": grpc_request["metadata"],
                 },
             )
-
         response = continuation(client_call_details, request)
         if logging_enabled:  # pragma: NO COVER
             response_metadata = response.trailing_metadata()
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/transports/grpc.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1/services/big_query_write/transports/grpc.py
@@ -69,12 +69,11 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
                 f"Sending request for {client_call_details.method}",
                 extra={
                     "serviceName": "google.cloud.bigquery.storage.v1.BigQueryWrite",
-                    "rpcName": client_call_details.method,
+                    "rpcName": str(client_call_details.method),
                     "request": grpc_request,
                     "metadata": grpc_request["metadata"],
                 },
             )
-
         response = continuation(client_call_details, request)
         if logging_enabled:  # pragma: NO COVER
             response_metadata = response.trailing_metadata()
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/async_client.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/async_client.py
@@ -65,7 +65,7 @@
 class MetastorePartitionServiceAsyncClient:
     """BigQuery Metastore Partition Service API.
     This service is used for managing metastore partitions in
-    BigQuery metastore. The service supports only batch operations
+    BigQuery  metastore. The service supports only batch operations
     for write.
     """
 
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/client.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/client.py
@@ -108,7 +108,7 @@ def get_transport_class(
 class MetastorePartitionServiceClient(metaclass=MetastorePartitionServiceClientMeta):
     """BigQuery Metastore Partition Service API.
     This service is used for managing metastore partitions in
-    BigQuery metastore. The service supports only batch operations
+    BigQuery  metastore. The service supports only batch operations
     for write.
     """
 
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/transports/grpc.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/transports/grpc.py
@@ -70,12 +70,11 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
                 f"Sending request for {client_call_details.method}",
                 extra={
                     "serviceName": "google.cloud.bigquery.storage.v1alpha.MetastorePartitionService",
-                    "rpcName": client_call_details.method,
+                    "rpcName": str(client_call_details.method),
                     "request": grpc_request,
                     "metadata": grpc_request["metadata"],
                 },
             )
-
         response = continuation(client_call_details, request)
         if logging_enabled:  # pragma: NO COVER
             response_metadata = response.trailing_metadata()
@@ -114,7 +113,7 @@ class MetastorePartitionServiceGrpcTransport(MetastorePartitionServiceTransport)
 
     BigQuery Metastore Partition Service API.
     This service is used for managing metastore partitions in
-    BigQuery metastore. The service supports only batch operations
+    BigQuery  metastore. The service supports only batch operations
     for write.
 
     This class defines the same methods as the primary client, so the
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/transports/grpc_asyncio.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/services/metastore_partition_service/transports/grpc_asyncio.py
@@ -119,7 +119,7 @@ class MetastorePartitionServiceGrpcAsyncIOTransport(MetastorePartitionServiceTra
 
     BigQuery Metastore Partition Service API.
     This service is used for managing metastore partitions in
-    BigQuery metastore. The service supports only batch operations
+    BigQuery  metastore. The service supports only batch operations
     for write.
 
     This class defines the same methods as the primary client, so the
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/types/metastore_partition.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1alpha/types/metastore_partition.py
@@ -86,7 +86,15 @@ class BatchCreateMetastorePartitionsRequest(proto.Message):
             add_partitions(..). If the flag is set to false, the server
             will return ALREADY_EXISTS if any partition already exists.
             If the flag is set to true, the server will skip existing
-            partitions and insert only the non-existing partitions.
+            partitions and insert only the non-existing partitions. A
+            maximum of 900 partitions can be inserted in a batch.
+        trace_id (str):
+            Optional. Optional trace id to be used for debugging. It is
+            expected that the client sets the same ``trace_id`` for all
+            the batches in the same operation, so that it is possible to
+            tie together the logs to all the batches in the same
+            operation. Limited to 256 characters. This is expected, but
+            not required, to be globally unique.
     """
 
     parent: str = proto.Field(
@@ -102,6 +110,10 @@ class BatchCreateMetastorePartitionsRequest(proto.Message):
         proto.BOOL,
         number=3,
     )
+    trace_id: str = proto.Field(
+        proto.STRING,
+        number=4,
+    )
 
 
 class BatchCreateMetastorePartitionsResponse(proto.Message):
@@ -135,8 +147,15 @@ class BatchDeleteMetastorePartitionsRequest(proto.Message):
         partition_values (MutableSequence[google.cloud.bigquery_storage_v1alpha.types.MetastorePartitionValues]):
             Required. The list of metastore partitions
             (identified by its values) to be deleted. A
-            maximum of 100 partitions can be deleted in a
+            maximum of 900 partitions can be deleted in a
             batch.
+        trace_id (str):
+            Optional. Optional trace id to be used for debugging. It is
+            expected that the client sets the same ``trace_id`` for all
+            the batches in the same operation, so that it is possible to
+            tie together the logs to all the batches in the same
+            operation. This is expected, but not required, to be
+            globally unique.
     """
 
     parent: str = proto.Field(
@@ -150,6 +169,10 @@ class BatchDeleteMetastorePartitionsRequest(proto.Message):
         number=2,
         message=partition.MetastorePartitionValues,
     )
+    trace_id: str = proto.Field(
+        proto.STRING,
+        number=4,
+    )
 
 
 class UpdateMetastorePartitionRequest(proto.Message):
@@ -187,6 +210,13 @@ class BatchUpdateMetastorePartitionsRequest(proto.Message):
         requests (MutableSequence[google.cloud.bigquery_storage_v1alpha.types.UpdateMetastorePartitionRequest]):
             Required. Requests to update metastore
             partitions in the table.
+        trace_id (str):
+            Optional. Optional trace id to be used for debugging. It is
+            expected that the client sets the same ``trace_id`` for all
+            the batches in the same operation, so that it is possible to
+            tie together the logs to all the batches in the same
+            operation. This is expected, but not required, to be
+            globally unique.
     """
 
     parent: str = proto.Field(
@@ -198,6 +228,10 @@ class BatchUpdateMetastorePartitionsRequest(proto.Message):
         number=2,
         message="UpdateMetastorePartitionRequest",
     )
+    trace_id: str = proto.Field(
+        proto.STRING,
+        number=4,
+    )
 
 
 class BatchUpdateMetastorePartitionsResponse(proto.Message):
@@ -206,7 +240,8 @@ class BatchUpdateMetastorePartitionsResponse(proto.Message):
     Attributes:
         partitions (MutableSequence[google.cloud.bigquery_storage_v1alpha.types.MetastorePartition]):
             The list of metastore partitions that have
-            been updated.
+            been updated. A maximum of 900 partitions can be
+            updated in a batch.
     """
 
     partitions: MutableSequence[partition.MetastorePartition] = proto.RepeatedField(
@@ -234,6 +269,13 @@ class ListMetastorePartitionsRequest(proto.Message):
             DATE)" "nullable_field is not NULL" "st_equals(geo_field,
             st_geofromtext("POINT(2, 2)"))" "numeric_field BETWEEN 1.0
             AND 5.0" Restricted to a maximum length for 1 MB.
+        trace_id (str):
+            Optional. Optional trace id to be used for debugging. It is
+            expected that the client sets the same ``trace_id`` for all
+            the batches in the same operation, so that it is possible to
+            tie together the logs to all the batches in the same
+            operation. Limited to 256 characters. This is expected, but
+            not required, to be globally unique.
     """
 
     parent: str = proto.Field(
@@ -244,6 +286,10 @@ class ListMetastorePartitionsRequest(proto.Message):
         proto.STRING,
         number=2,
     )
+    trace_id: str = proto.Field(
+        proto.STRING,
+        number=3,
+    )
 
 
 class ListMetastorePartitionsResponse(proto.Message):
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_read/transports/grpc.py
@@ -69,12 +69,11 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
                 f"Sending request for {client_call_details.method}",
                 extra={
                     "serviceName": "google.cloud.bigquery.storage.v1beta2.BigQueryRead",
-                    "rpcName": client_call_details.method,
+                    "rpcName": str(client_call_details.method),
                     "request": grpc_request,
                     "metadata": grpc_request["metadata"],
                 },
             )
-
         response = continuation(client_call_details, request)
         if logging_enabled:  # pragma: NO COVER
             response_metadata = response.trailing_metadata()
diff --git a/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/grpc.py b/packages/google-cloud-bigquery-storage/google/cloud/bigquery_storage_v1beta2/services/big_query_write/transports/grpc.py
@@ -69,12 +69,11 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
                 f"Sending request for {client_call_details.method}",
                 extra={
                     "serviceName": "google.cloud.bigquery.storage.v1beta2.BigQueryWrite",
-                    "rpcName": client_call_details.method,
+                    "rpcName": str(client_call_details.method),
                     "request": grpc_request,
                     "metadata": grpc_request["metadata"],
                 },
             )
-
         response = continuation(client_call_details, request)
         if logging_enabled:  # pragma: NO COVER
             response_metadata = response.trailing_metadata()
diff --git a/packages/google-cloud-bigquery-storage/samples/generated_samples/snippet_metadata_google.cloud.bigquery.storage.v1.json b/packages/google-cloud-bigquery-storage/samples/generated_samples/snippet_metadata_google.cloud.bigquery.storage.v1.json
@@ -8,7 +8,7 @@
     ],
     "language": "PYTHON",
     "name": "google-cloud-bigquery-storage",
-    "version": "2.30.0"
+    "version": "0.1.0"
   },
   "snippets": [
     {
diff --git a/packages/google-cloud-bigquery-storage/samples/generated_samples/snippet_metadata_google.cloud.bigquery.storage.v1beta2.json b/packages/google-cloud-bigquery-storage/samples/generated_samples/snippet_metadata_google.cloud.bigquery.storage.v1beta2.json
@@ -8,7 +8,7 @@
     ],
     "language": "PYTHON",
     "name": "google-cloud-bigquery-storage",
-    "version": "2.30.0"
+    "version": "0.1.0"
   },
   "snippets": [
     {
diff --git a/packages/google-cloud-bigquery-storage/scripts/fixup_bigquery_storage_v1alpha_keywords.py b/packages/google-cloud-bigquery-storage/scripts/fixup_bigquery_storage_v1alpha_keywords.py
@@ -39,10 +39,10 @@ def partition(
 class bigquery_storageCallTransformer(cst.CSTTransformer):
     CTRL_PARAMS: Tuple[str] = ('retry', 'timeout', 'metadata')
     METHOD_TO_PARAMS: Dict[str, Tuple[str]] = {
-        'batch_create_metastore_partitions': ('parent', 'requests', 'skip_existing_partitions', ),
-        'batch_delete_metastore_partitions': ('parent', 'partition_values', ),
-        'batch_update_metastore_partitions': ('parent', 'requests', ),
-        'list_metastore_partitions': ('parent', 'filter', ),
+        'batch_create_metastore_partitions': ('parent', 'requests', 'skip_existing_partitions', 'trace_id', ),
+        'batch_delete_metastore_partitions': ('parent', 'partition_values', 'trace_id', ),
+        'batch_update_metastore_partitions': ('parent', 'requests', 'trace_id', ),
+        'list_metastore_partitions': ('parent', 'filter', 'trace_id', ),
         'stream_metastore_partitions': ('parent', 'metastore_partitions', 'skip_existing_partitions', ),
     }
 
diff --git a/packages/google-cloud-bigquery-storage/testing/constraints-3.13.txt b/packages/google-cloud-bigquery-storage/testing/constraints-3.13.txt
@@ -1,6 +1,11 @@
-# -*- coding: utf-8 -*-
-# This constraints file is required for unit tests.
+# We use the constraints file for the latest Python version
+# (currently this file) to check that the latest
+# major versions of dependencies are supported in setup.py.
 # List all library dependencies and extras in this file.
-google-api-core
-proto-plus
-protobuf
+# Require the latest major version be installed for each dependency.
+# e.g., if setup.py has "google-cloud-foo >= 1.14.0, < 2.0.0",
+# Then this file should have google-cloud-foo>=1
+google-api-core>=2
+google-auth>=2
+proto-plus>=1
+protobuf>=6
diff --git a/packages/google-cloud-bigquery-storage/tests/unit/gapic/bigquery_storage_v1alpha/test_metastore_partition_service.py b/packages/google-cloud-bigquery-storage/tests/unit/gapic/bigquery_storage_v1alpha/test_metastore_partition_service.py
@@ -1196,6 +1196,7 @@ def test_batch_create_metastore_partitions_non_empty_request_with_auto_populated
     # if they meet the requirements of AIP 4235.
     request = metastore_partition.BatchCreateMetastorePartitionsRequest(
         parent="parent_value",
+        trace_id="trace_id_value",
     )
 
     # Mock the actual call within the gRPC stub, and fake the request.
@@ -1210,6 +1211,7 @@ def test_batch_create_metastore_partitions_non_empty_request_with_auto_populated
         _, args, _ = call.mock_calls[0]
         assert args[0] == metastore_partition.BatchCreateMetastorePartitionsRequest(
             parent="parent_value",
+            trace_id="trace_id_value",
         )
 
 
@@ -1449,6 +1451,7 @@ def test_batch_delete_metastore_partitions_non_empty_request_with_auto_populated
     # if they meet the requirements of AIP 4235.
     request = metastore_partition.BatchDeleteMetastorePartitionsRequest(
         parent="parent_value",
+        trace_id="trace_id_value",
     )
 
     # Mock the actual call within the gRPC stub, and fake the request.
@@ -1463,6 +1466,7 @@ def test_batch_delete_metastore_partitions_non_empty_request_with_auto_populated
         _, args, _ = call.mock_calls[0]
         assert args[0] == metastore_partition.BatchDeleteMetastorePartitionsRequest(
             parent="parent_value",
+            trace_id="trace_id_value",
         )
 
 
@@ -1698,6 +1702,7 @@ def test_batch_update_metastore_partitions_non_empty_request_with_auto_populated
     # if they meet the requirements of AIP 4235.
     request = metastore_partition.BatchUpdateMetastorePartitionsRequest(
         parent="parent_value",
+        trace_id="trace_id_value",
     )
 
     # Mock the actual call within the gRPC stub, and fake the request.
@@ -1712,6 +1717,7 @@ def test_batch_update_metastore_partitions_non_empty_request_with_auto_populated
         _, args, _ = call.mock_calls[0]
         assert args[0] == metastore_partition.BatchUpdateMetastorePartitionsRequest(
             parent="parent_value",
+            trace_id="trace_id_value",
         )
 
 
@@ -1952,6 +1958,7 @@ def test_list_metastore_partitions_non_empty_request_with_auto_populated_field()
     request = metastore_partition.ListMetastorePartitionsRequest(
         parent="parent_value",
         filter="filter_value",
+        trace_id="trace_id_value",
     )
 
     # Mock the actual call within the gRPC stub, and fake the request.
@@ -1967,6 +1974,7 @@ def test_list_metastore_partitions_non_empty_request_with_auto_populated_field()
         assert args[0] == metastore_partition.ListMetastorePartitionsRequest(
             parent="parent_value",
             filter="filter_value",
+            trace_id="trace_id_value",
         )
 
 

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@`
`8`	`8`	`],`
`9`	`9`	`"language": "PYTHON",`
`10`	`10`	`"name": "google-cloud-bigquery-storage",`
`11`		`- "version": "2.30.0"`
	`11`	`+ "version": "0.1.0"`
`12`	`12`	`},`
`13`	`13`	`"snippets": [`
`14`	`14`	`{`