From 0321915e31c12f24e96b778b5b3814507ff547d6 Mon Sep 17 00:00:00 2001 From: "gcf-owl-bot[bot]" <78513119+gcf-owl-bot[bot]@users.noreply.github.com> Date: Tue, 3 Sep 2024 12:37:18 -0400 Subject: [PATCH] feat: [google-cloud-visionai] request client libraries for new languages (#13036) BEGIN_COMMIT_OVERRIDE feat: request client libraries for new languages feat: add BatchOperationStatus to import metadata docs: A comment for method `ClipAsset` in service `Warehouse` is changed docs: A comment for enum value `IN_PROGRESS` in enum `State` is changed docs: A comment for enum value `SUCCEEDED` in enum `State` is changed docs: A comment for enum value `FAILED` in enum `State` is changed docs: A comment for field `relevance` in message `.google.cloud.visionai.v1.SearchResultItem` is changed END_COMMIT_OVERRIDE - [ ] Regenerate this pull request now. feat: add BatchOperationStatus to import metadata docs: A comment for method `ClipAsset` in service `Warehouse` is changed docs: A comment for enum value `IN_PROGRESS` in enum `State` is changed docs: A comment for enum value `SUCCEEDED` in enum `State` is changed docs: A comment for enum value `FAILED` in enum `State` is changed docs: A comment for field `relevance` in message `.google.cloud.visionai.v1.SearchResultItem` is changed PiperOrigin-RevId: 667729001 Source-Link: https://github.com/googleapis/googleapis/commit/f17f11412a8770c52e7280fa0e66ab17cb2f3af9 Source-Link: https://github.com/googleapis/googleapis-gen/commit/da60873b0b72c5750144c58b761218c8eb7f8cb4 Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLXZpc2lvbmFpLy5Pd2xCb3QueWFtbCIsImgiOiJkYTYwODczYjBiNzJjNTc1MDE0NGM1OGI3NjEyMThjOGViN2Y4Y2I0In0= --------- Co-authored-by: Owl Bot Co-authored-by: ohmayr --- .../google/cloud/visionai/__init__.py | 2 + .../google/cloud/visionai_v1/__init__.py | 2 + .../services/warehouse/async_client.py | 11 +- .../visionai_v1/services/warehouse/client.py | 11 +- .../services/warehouse/transports/grpc.py | 11 +- .../warehouse/transports/grpc_asyncio.py | 11 +- .../cloud/visionai_v1/types/__init__.py | 2 + .../cloud/visionai_v1/types/warehouse.py | 135 ++++++++++++++++-- .../unit/gapic/visionai_v1/test_warehouse.py | 68 +++++++++ 9 files changed, 225 insertions(+), 28 deletions(-) diff --git a/packages/google-cloud-visionai/google/cloud/visionai/__init__.py b/packages/google-cloud-visionai/google/cloud/visionai/__init__.py index ccaffd1a09fa..1849c4efa2ad 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai/__init__.py +++ b/packages/google-cloud-visionai/google/cloud/visionai/__init__.py @@ -276,6 +276,7 @@ AnnotationValue, Asset, AssetSource, + BatchOperationStatus, BoolValue, CircleArea, ClipAssetRequest, @@ -640,6 +641,7 @@ "AnnotationValue", "Asset", "AssetSource", + "BatchOperationStatus", "BoolValue", "CircleArea", "ClipAssetRequest", diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/__init__.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/__init__.py index 82e8e3764093..732d7a958c52 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/__init__.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/__init__.py @@ -250,6 +250,7 @@ AnnotationValue, Asset, AssetSource, + BatchOperationStatus, BoolValue, CircleArea, ClipAssetRequest, @@ -432,6 +433,7 @@ "AssetSource", "AttributeValue", "AutoscalingMetricSpec", + "BatchOperationStatus", "BatchRunProcessRequest", "BatchRunProcessResponse", "BigQueryConfig", diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/async_client.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/async_client.py index e33e38726d0e..85335ef56434 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/async_client.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/async_client.py @@ -4057,11 +4057,12 @@ async def clip_asset( timeout: Union[float, object] = gapic_v1.method.DEFAULT, metadata: Sequence[Tuple[str, str]] = (), ) -> warehouse.ClipAssetResponse: - r"""Generates clips for downloading. The api takes in a time range, - and generates a clip of the first content available after - start_time and before end_time, which may overflow beyond these - bounds. Returned clips are truncated if the total size of the - clips are larger than 100MB. + r"""Supported by STREAM_VIDEO corpus type. Generates clips for + downloading. The api takes in a time range, and generates a clip + of the first content available after start_time and before + end_time, which may overflow beyond these bounds. Returned clips + are truncated if the total size of the clips are larger than + 100MB. .. code-block:: python diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/client.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/client.py index a7b0f4fa4c78..a8da521a4414 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/client.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/client.py @@ -4562,11 +4562,12 @@ def clip_asset( timeout: Union[float, object] = gapic_v1.method.DEFAULT, metadata: Sequence[Tuple[str, str]] = (), ) -> warehouse.ClipAssetResponse: - r"""Generates clips for downloading. The api takes in a time range, - and generates a clip of the first content available after - start_time and before end_time, which may overflow beyond these - bounds. Returned clips are truncated if the total size of the - clips are larger than 100MB. + r"""Supported by STREAM_VIDEO corpus type. Generates clips for + downloading. The api takes in a time range, and generates a clip + of the first content available after start_time and before + end_time, which may overflow beyond these bounds. Returned clips + are truncated if the total size of the clips are larger than + 100MB. .. code-block:: python diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc.py index df1b049eebc6..372e53e0beca 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc.py @@ -1142,11 +1142,12 @@ def clip_asset( ) -> Callable[[warehouse.ClipAssetRequest], warehouse.ClipAssetResponse]: r"""Return a callable for the clip asset method over gRPC. - Generates clips for downloading. The api takes in a time range, - and generates a clip of the first content available after - start_time and before end_time, which may overflow beyond these - bounds. Returned clips are truncated if the total size of the - clips are larger than 100MB. + Supported by STREAM_VIDEO corpus type. Generates clips for + downloading. The api takes in a time range, and generates a clip + of the first content available after start_time and before + end_time, which may overflow beyond these bounds. Returned clips + are truncated if the total size of the clips are larger than + 100MB. Returns: Callable[[~.ClipAssetRequest], diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc_asyncio.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc_asyncio.py index d7eef7e7e00e..dccfe2920d8b 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc_asyncio.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/services/warehouse/transports/grpc_asyncio.py @@ -1172,11 +1172,12 @@ def clip_asset( ) -> Callable[[warehouse.ClipAssetRequest], Awaitable[warehouse.ClipAssetResponse]]: r"""Return a callable for the clip asset method over gRPC. - Generates clips for downloading. The api takes in a time range, - and generates a clip of the first content available after - start_time and before end_time, which may overflow beyond these - bounds. Returned clips are truncated if the total size of the - clips are larger than 100MB. + Supported by STREAM_VIDEO corpus type. Generates clips for + downloading. The api takes in a time range, and generates a clip + of the first content available after start_time and before + end_time, which may overflow beyond these bounds. Returned clips + are truncated if the total size of the clips are larger than + 100MB. Returns: Callable[[~.ClipAssetRequest], diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/types/__init__.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/types/__init__.py index df36023a838c..08ebd9fab538 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/types/__init__.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/types/__init__.py @@ -230,6 +230,7 @@ AnnotationValue, Asset, AssetSource, + BatchOperationStatus, BoolValue, CircleArea, ClipAssetRequest, @@ -582,6 +583,7 @@ "AnnotationValue", "Asset", "AssetSource", + "BatchOperationStatus", "BoolValue", "CircleArea", "ClipAssetRequest", diff --git a/packages/google-cloud-visionai/google/cloud/visionai_v1/types/warehouse.py b/packages/google-cloud-visionai/google/cloud/visionai_v1/types/warehouse.py index 92451e6b9b0e..a236ffe33e3e 100644 --- a/packages/google-cloud-visionai/google/cloud/visionai_v1/types/warehouse.py +++ b/packages/google-cloud-visionai/google/cloud/visionai_v1/types/warehouse.py @@ -120,6 +120,7 @@ "DeleteAnnotationRequest", "ImportAssetsRequest", "ImportAssetsMetadata", + "BatchOperationStatus", "ImportAssetsResponse", "CreateSearchConfigRequest", "UpdateSearchConfigRequest", @@ -607,11 +608,11 @@ class State(proto.Enum): The default process state should never happen. IN_PROGRESS (1): - The feature is in progress. + The ml model analysis is in progress. SUCCEEDED (2): - The process is successfully done. + The ml model analysis is successfully done. FAILED (3): - The process failed. + The ml model analysis failed. """ STATE_UNSPECIFIED = 0 IN_PROGRESS = 1 @@ -1629,6 +1630,22 @@ class Index(proto.Message): Index of VIDEO_ON_DEMAND corpus can have at most one deployed index. Index of IMAGE corpus can have multiple deployed indexes. + satisfies_pzs (bool): + Output only. This boolean field is only set + for projects that have Physical Zone Separation + enabled via an Org Policy constraint. It is set + to true when the index is a valid zone separated + index and false if it isn't. + + This field is a member of `oneof`_ ``_satisfies_pzs``. + satisfies_pzi (bool): + Output only. This boolean field is only set + for projects that have Physical Zone Isolation + enabled via an Org Policy constraint. It is set + to true when the index is a valid zone isolated + index and false if it isn't. + + This field is a member of `oneof`_ ``_satisfies_pzi``. """ class State(proto.Enum): @@ -1687,6 +1704,16 @@ class State(proto.Enum): number=8, message="DeployedIndexReference", ) + satisfies_pzs: bool = proto.Field( + proto.BOOL, + number=11, + optional=True, + ) + satisfies_pzi: bool = proto.Field( + proto.BOOL, + number=12, + optional=True, + ) class DeployedIndexReference(proto.Message): @@ -1709,6 +1736,9 @@ class Corpus(proto.Message): Within a corpus, media shares the same data schema. Search is also restricted within a single corpus. + + .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields + Attributes: name (str): Resource name of the corpus. Format: @@ -1729,6 +1759,22 @@ class Corpus(proto.Message): search_capability_setting (google.cloud.visionai_v1.types.SearchCapabilitySetting): Default search capability setting on corpus level. + satisfies_pzs (bool): + Output only. This boolean field is only set + for projects that have Physical Zone Separation + enabled via an Org Policy constraint. It is set + to true when the corpus is a valid zone + separated corpus and false if it isn't. + + This field is a member of `oneof`_ ``_satisfies_pzs``. + satisfies_pzi (bool): + Output only. This boolean field is only set + for projects that have Physical Zone Isolation + enabled via an Org Policy constraint. It is set + to true when the corpus is a valid zone isolated + corpus and false if it isn't. + + This field is a member of `oneof`_ ``_satisfies_pzi``. """ class Type(proto.Enum): @@ -1778,6 +1824,16 @@ class Type(proto.Enum): number=8, message="SearchCapabilitySetting", ) + satisfies_pzs: bool = proto.Field( + proto.BOOL, + number=11, + optional=True, + ) + satisfies_pzi: bool = proto.Field( + proto.BOOL, + number=12, + optional=True, + ) class GetCorpusRequest(proto.Message): @@ -2874,6 +2930,11 @@ class ImportAssetsMetadata(proto.Message): Attributes: metadata (google.cloud.visionai_v1.types.OperationMetadata): The metadata of the operation. + status (google.cloud.visionai_v1.types.BatchOperationStatus): + The importing status including partial + failures, if the implementation can provide such + information during the progress of the + ImportAssets. """ metadata: common.OperationMetadata = proto.Field( @@ -2881,6 +2942,33 @@ class ImportAssetsMetadata(proto.Message): number=1, message=common.OperationMetadata, ) + status: "BatchOperationStatus" = proto.Field( + proto.MESSAGE, + number=2, + message="BatchOperationStatus", + ) + + +class BatchOperationStatus(proto.Message): + r"""The batch operation status. + + Attributes: + success_count (int): + The count of assets (together with their + annotations if any) successfully ingested. + failure_count (int): + The count of assets failed to ingested; it + might be due to the annotation ingestion error. + """ + + success_count: int = proto.Field( + proto.INT32, + number=1, + ) + failure_count: int = proto.Field( + proto.INT32, + number=2, + ) class ImportAssetsResponse(proto.Message): @@ -3084,6 +3172,9 @@ class IndexEndpoint(proto.Message): r"""Message representing IndexEndpoint resource. Indexes are deployed into it. + + .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields + Attributes: name (str): Output only. Resource name of the IndexEndpoint. Format: @@ -3125,6 +3216,22 @@ class IndexEndpoint(proto.Message): Output only. Create timestamp. update_time (google.protobuf.timestamp_pb2.Timestamp): Output only. Update timestamp. + satisfies_pzs (bool): + Output only. This boolean field is only set + for projects that have Physical Zone Separation + enabled via an Org Policy constraint. It is set + to true when the index endpoint is a valid zone + separated index endpoint and false if it isn't. + + This field is a member of `oneof`_ ``_satisfies_pzs``. + satisfies_pzi (bool): + Output only. This boolean field is only set + for projects that have Physical Zone Isolation + enabled via an Org Policy constraint. It is set + to true when the index endpoint is a valid zone + isolated index endpoint and false if it isn't. + + This field is a member of `oneof`_ ``_satisfies_pzi``. """ class State(proto.Enum): @@ -3185,6 +3292,16 @@ class State(proto.Enum): number=8, message=timestamp_pb2.Timestamp, ) + satisfies_pzs: bool = proto.Field( + proto.BOOL, + number=10, + optional=True, + ) + satisfies_pzi: bool = proto.Field( + proto.BOOL, + number=11, + optional=True, + ) class CreateIndexEndpointRequest(proto.Message): @@ -4639,11 +4756,13 @@ class SearchResultItem(proto.Message): segment (google.cloud.visionai_v1.types.Partition.TemporalPartition): The matched asset segment. relevance (float): - Relevance of this ``SearchResultItem`` to user search - request. Currently available only in Image Warehouse, and by - default represents cosine similarity. In the future can be - other measures such as "dot product" or "topicality" - requested in the search request. + Available to IMAGE corpus types. Relevance of this + ``SearchResultItem`` to user search query (text query or + image query). By default this represents cosine similarity + between the query and the retrieved media content. The value + is in the range of [-1, 1]. Note that search ranking is not + only decided by this relevance score, but also other factors + such as the match of annotations. requested_annotations (MutableSequence[google.cloud.visionai_v1.types.Annotation]): Search result annotations specified by result_annotation_keys in search request. diff --git a/packages/google-cloud-visionai/tests/unit/gapic/visionai_v1/test_warehouse.py b/packages/google-cloud-visionai/tests/unit/gapic/visionai_v1/test_warehouse.py index 0b6e0f0a95cc..4cfebb38f721 100644 --- a/packages/google-cloud-visionai/tests/unit/gapic/visionai_v1/test_warehouse.py +++ b/packages/google-cloud-visionai/tests/unit/gapic/visionai_v1/test_warehouse.py @@ -5976,6 +5976,8 @@ def test_get_index(request_type, transport: str = "grpc"): display_name="display_name_value", description="description_value", state=warehouse.Index.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, entire_corpus=True, ) response = client.get_index(request) @@ -5992,6 +5994,8 @@ def test_get_index(request_type, transport: str = "grpc"): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.state == warehouse.Index.State.CREATING + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_get_index_empty_call(): @@ -6094,6 +6098,8 @@ async def test_get_index_empty_call_async(): display_name="display_name_value", description="description_value", state=warehouse.Index.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.get_index() @@ -6164,6 +6170,8 @@ async def test_get_index_async( display_name="display_name_value", description="description_value", state=warehouse.Index.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.get_index(request) @@ -6180,6 +6188,8 @@ async def test_get_index_async( assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.state == warehouse.Index.State.CREATING + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True @pytest.mark.asyncio @@ -7656,6 +7666,8 @@ def test_get_corpus(request_type, transport: str = "grpc"): display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) response = client.get_corpus(request) @@ -7671,6 +7683,8 @@ def test_get_corpus(request_type, transport: str = "grpc"): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.type_ == warehouse.Corpus.Type.STREAM_VIDEO + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_get_corpus_empty_call(): @@ -7773,6 +7787,8 @@ async def test_get_corpus_empty_call_async(): display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.get_corpus() @@ -7843,6 +7859,8 @@ async def test_get_corpus_async( display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.get_corpus(request) @@ -7859,6 +7877,8 @@ async def test_get_corpus_async( assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.type_ == warehouse.Corpus.Type.STREAM_VIDEO + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True @pytest.mark.asyncio @@ -8030,6 +8050,8 @@ def test_update_corpus(request_type, transport: str = "grpc"): display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) response = client.update_corpus(request) @@ -8045,6 +8067,8 @@ def test_update_corpus(request_type, transport: str = "grpc"): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.type_ == warehouse.Corpus.Type.STREAM_VIDEO + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_update_corpus_empty_call(): @@ -8143,6 +8167,8 @@ async def test_update_corpus_empty_call_async(): display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.update_corpus() @@ -8215,6 +8241,8 @@ async def test_update_corpus_async( display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.update_corpus(request) @@ -8231,6 +8259,8 @@ async def test_update_corpus_async( assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.type_ == warehouse.Corpus.Type.STREAM_VIDEO + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True @pytest.mark.asyncio @@ -20567,6 +20597,8 @@ def test_get_index_endpoint(request_type, transport: str = "grpc"): display_name="display_name_value", description="description_value", state=warehouse.IndexEndpoint.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, ) response = client.get_index_endpoint(request) @@ -20582,6 +20614,8 @@ def test_get_index_endpoint(request_type, transport: str = "grpc"): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.state == warehouse.IndexEndpoint.State.CREATING + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_get_index_endpoint_empty_call(): @@ -20694,6 +20728,8 @@ async def test_get_index_endpoint_empty_call_async(): display_name="display_name_value", description="description_value", state=warehouse.IndexEndpoint.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.get_index_endpoint() @@ -20768,6 +20804,8 @@ async def test_get_index_endpoint_async( display_name="display_name_value", description="description_value", state=warehouse.IndexEndpoint.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, ) ) response = await client.get_index_endpoint(request) @@ -20784,6 +20822,8 @@ async def test_get_index_endpoint_async( assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.state == warehouse.IndexEndpoint.State.CREATING + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True @pytest.mark.asyncio @@ -29750,6 +29790,8 @@ def test_create_index_rest(request_type): "create_time": {"seconds": 751, "nanos": 543}, "update_time": {}, "deployed_indexes": [{"index_endpoint": "index_endpoint_value"}], + "satisfies_pzs": True, + "satisfies_pzi": True, } # The version of a generated dependency at test runtime may differ from the version used during generation. # Delete any fields which are not present in the current runtime dependency @@ -30141,6 +30183,8 @@ def test_update_index_rest(request_type): "create_time": {"seconds": 751, "nanos": 543}, "update_time": {}, "deployed_indexes": [{"index_endpoint": "index_endpoint_value"}], + "satisfies_pzs": True, + "satisfies_pzi": True, } # The version of a generated dependency at test runtime may differ from the version used during generation. # Delete any fields which are not present in the current runtime dependency @@ -30530,6 +30574,8 @@ def test_get_index_rest(request_type): display_name="display_name_value", description="description_value", state=warehouse.Index.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, entire_corpus=True, ) @@ -30550,6 +30596,8 @@ def test_get_index_rest(request_type): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.state == warehouse.Index.State.CREATING + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_get_index_rest_use_cached_wrapped_rpc(): @@ -31503,6 +31551,8 @@ def test_create_corpus_rest(request_type): "default_ttl": {"seconds": 751, "nanos": 543}, "type_": 1, "search_capability_setting": {"search_capabilities": [{"type_": 1}]}, + "satisfies_pzs": True, + "satisfies_pzi": True, } # The version of a generated dependency at test runtime may differ from the version used during generation. # Delete any fields which are not present in the current runtime dependency @@ -31884,6 +31934,8 @@ def test_get_corpus_rest(request_type): display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) # Wrap the value into a proper Response obj @@ -31903,6 +31955,8 @@ def test_get_corpus_rest(request_type): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.type_ == warehouse.Corpus.Type.STREAM_VIDEO + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_get_corpus_rest_use_cached_wrapped_rpc(): @@ -32183,6 +32237,8 @@ def test_update_corpus_rest(request_type): "default_ttl": {"seconds": 751, "nanos": 543}, "type_": 1, "search_capability_setting": {"search_capabilities": [{"type_": 1}]}, + "satisfies_pzs": True, + "satisfies_pzi": True, } # The version of a generated dependency at test runtime may differ from the version used during generation. # Delete any fields which are not present in the current runtime dependency @@ -32261,6 +32317,8 @@ def get_message_fields(field): display_name="display_name_value", description="description_value", type_=warehouse.Corpus.Type.STREAM_VIDEO, + satisfies_pzs=True, + satisfies_pzi=True, ) # Wrap the value into a proper Response obj @@ -32280,6 +32338,8 @@ def get_message_fields(field): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.type_ == warehouse.Corpus.Type.STREAM_VIDEO + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_update_corpus_rest_use_cached_wrapped_rpc(): @@ -41934,6 +41994,8 @@ def test_create_index_endpoint_rest(request_type): "labels": {}, "create_time": {"seconds": 751, "nanos": 543}, "update_time": {}, + "satisfies_pzs": True, + "satisfies_pzi": True, } # The version of a generated dependency at test runtime may differ from the version used during generation. # Delete any fields which are not present in the current runtime dependency @@ -42329,6 +42391,8 @@ def test_get_index_endpoint_rest(request_type): display_name="display_name_value", description="description_value", state=warehouse.IndexEndpoint.State.CREATING, + satisfies_pzs=True, + satisfies_pzi=True, ) # Wrap the value into a proper Response obj @@ -42348,6 +42412,8 @@ def test_get_index_endpoint_rest(request_type): assert response.display_name == "display_name_value" assert response.description == "description_value" assert response.state == warehouse.IndexEndpoint.State.CREATING + assert response.satisfies_pzs is True + assert response.satisfies_pzi is True def test_get_index_endpoint_rest_use_cached_wrapped_rpc(): @@ -43024,6 +43090,8 @@ def test_update_index_endpoint_rest(request_type): "labels": {}, "create_time": {"seconds": 751, "nanos": 543}, "update_time": {}, + "satisfies_pzs": True, + "satisfies_pzi": True, } # The version of a generated dependency at test runtime may differ from the version used during generation. # Delete any fields which are not present in the current runtime dependency