From 6557767c67d2b4461aa8e7c44d10b1572eceefeb Mon Sep 17 00:00:00 2001 From: "gcf-owl-bot[bot]" <78513119+gcf-owl-bot[bot]@users.noreply.github.com> Date: Fri, 3 Jun 2022 09:57:29 -0700 Subject: [PATCH] feat: add IAM policy to aiplatform_v1beta1.yaml (#308) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * fix: fixes for dynamic routing and streaming descriptors Use gapic-generator-typescript v2.14.5. PiperOrigin-RevId: 450616838 Source-Link: https://github.com/googleapis/googleapis/commit/7a47b72791e0b84d78beca4c2b26bec42ce31572 Source-Link: https://github.com/googleapis/googleapis-gen/commit/42cc6331bae0b99f61b8e01ae15b05211716c4f9 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNDJjYzYzMzFiYWUwYjk5ZjYxYjhlMDFhZTE1YjA1MjExNzE2YzRmOSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add latent_space_source to ExplanationMetadata in aiplatform v1 explanation_metadata.proto feat: add scaling to OnlineServingConfig in aiplatform v1 featurestore.proto feat: add template_metadata to PipelineJob in aiplatform v1 pipeline_job.proto PiperOrigin-RevId: 450687287 Source-Link: https://github.com/googleapis/googleapis/commit/058bff383bb3810ecbf30a6dfb85566313d5d63a Source-Link: https://github.com/googleapis/googleapis-gen/commit/f072bfe7704d996c41d74ac3aa1d8514f464c4ff Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZjA3MmJmZTc3MDRkOTk2YzQxZDc0YWMzYWExZDg1MTRmNDY0YzRmZiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add failure_policy to PipelineJob in aiplatform v1 & v1beta1 pipeline_job.proto PiperOrigin-RevId: 450704795 Source-Link: https://github.com/googleapis/googleapis/commit/c875f2b202e338381158637e787e2fdc57a0c4fa Source-Link: https://github.com/googleapis/googleapis-gen/commit/e606d62ab32b85434697678b3004f2206d5c02ae Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZTYwNmQ2MmFiMzJiODU0MzQ2OTc2NzhiMzAwNGYyMjA2ZDVjMDJhZSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add IAM policy to aiplatform_v1beta1.yaml feat: add preset configuration for example-based explanations in aiplatform v1beta1 explanation.proto feat: add latent_space_source to ExplanationMetadata in aiplatform v1beta1 explanation_metadata.proto feat: add successful_forecast_point_count to CompletionStats in completion_stats.proto PiperOrigin-RevId: 450727462 Source-Link: https://github.com/googleapis/googleapis/commit/665682daa0a04d210407434974c81cce09f93ece Source-Link: https://github.com/googleapis/googleapis-gen/commit/34cddbef39c17c58f96f5ffebf6065136b6d5719 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMzRjZGRiZWYzOWMxN2M1OGY5NmY1ZmZlYmY2MDY1MTM2YjZkNTcxOSJ9 * 🦉 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 --- .../google/cloud/aiplatform/v1/endpoint.proto | 4 +- .../aiplatform/v1/explanation_metadata.proto | 3 + .../cloud/aiplatform/v1/featurestore.proto | 18 + .../v1/manual_batch_tuning_parameters.proto | 2 +- .../aiplatform/v1/model_monitoring.proto | 2 + .../v1/pipeline_failure_policy.proto | 44 + .../cloud/aiplatform/v1/pipeline_job.proto | 30 + .../aiplatform/v1/pipeline_service.proto | 2 +- .../v1beta1/batch_prediction_job.proto | 3 + .../aiplatform/v1beta1/completion_stats.proto | 4 + .../cloud/aiplatform/v1beta1/endpoint.proto | 7 +- .../aiplatform/v1beta1/explanation.proto | 4 +- .../v1beta1/featurestore_online_service.proto | 1 - .../manual_batch_tuning_parameters.proto | 2 +- .../aiplatform/v1beta1/model_monitoring.proto | 2 + .../aiplatform/v1beta1/model_service.proto | 6 +- .../v1beta1/pipeline_failure_policy.proto | 44 + .../aiplatform/v1beta1/pipeline_job.proto | 9 + .../aiplatform/v1beta1/pipeline_service.proto | 2 +- protos/protos.d.ts | 333 ++++++- protos/protos.js | 827 ++++++++++++++++-- protos/protos.json | 81 +- .../v1/pipeline_service.list_pipeline_jobs.js | 2 +- .../v1beta1/model_service.get_model.js | 4 +- .../pipeline_service.list_pipeline_jobs.js | 2 +- ...adata.google.cloud.aiplatform.v1beta1.json | 2 +- src/v1/dataset_service_proto_list.json | 1 + src/v1/endpoint_service_proto_list.json | 1 + ...turestore_online_serving_service_client.ts | 3 +- ...ore_online_serving_service_proto_list.json | 1 + src/v1/featurestore_service_proto_list.json | 1 + src/v1/index_endpoint_service_proto_list.json | 1 + src/v1/index_service_proto_list.json | 1 + src/v1/job_service_proto_list.json | 1 + src/v1/metadata_service_proto_list.json | 1 + src/v1/migration_service_proto_list.json | 1 + src/v1/model_service_proto_list.json | 1 + src/v1/pipeline_service_client.ts | 6 +- src/v1/pipeline_service_proto_list.json | 1 + src/v1/prediction_service_proto_list.json | 1 + .../specialist_pool_service_proto_list.json | 1 + src/v1/tensorboard_service_client.ts | 3 +- src/v1/tensorboard_service_proto_list.json | 1 + src/v1/vizier_service_proto_list.json | 1 + src/v1beta1/dataset_service_proto_list.json | 1 + src/v1beta1/endpoint_service_proto_list.json | 1 + ...turestore_online_serving_service_client.ts | 3 +- ...ore_online_serving_service_proto_list.json | 1 + .../featurestore_service_proto_list.json | 1 + .../index_endpoint_service_proto_list.json | 1 + src/v1beta1/index_service_proto_list.json | 1 + src/v1beta1/job_service_proto_list.json | 1 + src/v1beta1/metadata_service_proto_list.json | 1 + src/v1beta1/migration_service_proto_list.json | 1 + src/v1beta1/model_service_client.ts | 6 +- src/v1beta1/model_service_proto_list.json | 1 + src/v1beta1/pipeline_service_client.ts | 6 +- src/v1beta1/pipeline_service_proto_list.json | 1 + .../prediction_service_proto_list.json | 1 + .../specialist_pool_service_proto_list.json | 1 + src/v1beta1/tensorboard_service_client.ts | 3 +- .../tensorboard_service_proto_list.json | 1 + src/v1beta1/vizier_service_proto_list.json | 1 + 63 files changed, 1330 insertions(+), 170 deletions(-) create mode 100644 protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto create mode 100644 protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto diff --git a/protos/google/cloud/aiplatform/v1/endpoint.proto b/protos/google/cloud/aiplatform/v1/endpoint.proto index 453cc89a..e8c5ff03 100644 --- a/protos/google/cloud/aiplatform/v1/endpoint.proto +++ b/protos/google/cloud/aiplatform/v1/endpoint.proto @@ -154,8 +154,8 @@ message DeployedModel { // This value should be 1-10 characters, and valid characters are /[0-9]/. string id = 1 [(google.api.field_behavior) = IMMUTABLE]; - // Required. The name of the Model that this is the deployment of. Note that the Model - // may be in a different location than the DeployedModel's Endpoint. + // Required. The resource name of the Model that this is the deployment of. Note that + // the Model may be in a different location than the DeployedModel's Endpoint. string model = 2 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { diff --git a/protos/google/cloud/aiplatform/v1/explanation_metadata.proto b/protos/google/cloud/aiplatform/v1/explanation_metadata.proto index f0da95fe..5ee0c1ce 100644 --- a/protos/google/cloud/aiplatform/v1/explanation_metadata.proto +++ b/protos/google/cloud/aiplatform/v1/explanation_metadata.proto @@ -392,4 +392,7 @@ message ExplanationMetadata { // than the one given on input. The output URI will point to a location where // the user only has a read access. string feature_attributions_schema_uri = 3; + + // Name of the source to generate embeddings for example based explanations. + string latent_space_source = 5; } diff --git a/protos/google/cloud/aiplatform/v1/featurestore.proto b/protos/google/cloud/aiplatform/v1/featurestore.proto index 535ca6b9..4c8a72f5 100644 --- a/protos/google/cloud/aiplatform/v1/featurestore.proto +++ b/protos/google/cloud/aiplatform/v1/featurestore.proto @@ -41,11 +41,29 @@ message Featurestore { // OnlineServingConfig specifies the details for provisioning online serving // resources. message OnlineServingConfig { + // Online serving scaling configuration. If min_node_count and + // max_node_count are set to the same value, the cluster will be configured + // with the fixed number of node (no auto-scaling). + message Scaling { + // Required. The minimum number of nodes to scale down to. Must be greater than or + // equal to 1. + int32 min_node_count = 1 [(google.api.field_behavior) = REQUIRED]; + + // The maximum number of nodes to scale up to. Must be greater than + // min_node_count, and less than or equal to 10 times of 'min_node_count'. + int32 max_node_count = 2; + } + // The number of nodes for the online store. The number of nodes doesn't // scale automatically, but you can manually update the number of // nodes. If set to 0, the featurestore will not have an // online store and cannot be used for online serving. int32 fixed_node_count = 2; + + // Online serving scaling configuration. + // Only one of `fixed_node_count` and `scaling` can be set. Setting one will + // reset the other. + Scaling scaling = 4; } // Possible states a featurestore can have. diff --git a/protos/google/cloud/aiplatform/v1/manual_batch_tuning_parameters.proto b/protos/google/cloud/aiplatform/v1/manual_batch_tuning_parameters.proto index 54002126..e469d45e 100644 --- a/protos/google/cloud/aiplatform/v1/manual_batch_tuning_parameters.proto +++ b/protos/google/cloud/aiplatform/v1/manual_batch_tuning_parameters.proto @@ -34,6 +34,6 @@ message ManualBatchTuningParameters { // speeds up the batch operation's execution, but too high value will result // in a whole batch not fitting in a machine's memory, and the whole // operation will fail. - // The default value is 4. + // The default value is 64. int32 batch_size = 1 [(google.api.field_behavior) = IMMUTABLE]; } diff --git a/protos/google/cloud/aiplatform/v1/model_monitoring.proto b/protos/google/cloud/aiplatform/v1/model_monitoring.proto index 0daff79d..2ac8b37d 100644 --- a/protos/google/cloud/aiplatform/v1/model_monitoring.proto +++ b/protos/google/cloud/aiplatform/v1/model_monitoring.proto @@ -55,6 +55,8 @@ message ModelMonitoringObjectiveConfig { // // "csv" // The source file is a CSV file. + // "jsonl" + // The source file is a JSONL file. string data_format = 2; // The target field name the model is to predict. diff --git a/protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto b/protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto new file mode 100644 index 00000000..5ff3b78b --- /dev/null +++ b/protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto @@ -0,0 +1,44 @@ +// Copyright 2022 Google LLC +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +syntax = "proto3"; + +package google.cloud.aiplatform.v1; + +option csharp_namespace = "Google.Cloud.AIPlatform.V1"; +option go_package = "google.golang.org/genproto/googleapis/cloud/aiplatform/v1;aiplatform"; +option java_multiple_files = true; +option java_outer_classname = "PipelineFailurePolicyProto"; +option java_package = "com.google.cloud.aiplatform.v1"; +option php_namespace = "Google\\Cloud\\AIPlatform\\V1"; +option ruby_package = "Google::Cloud::AIPlatform::V1"; + +// Represents the failure policy of a pipeline. Currently, the default of a +// pipeline is that the pipeline will continue to run until no more tasks can be +// executed, also known as PIPELINE_FAILURE_POLICY_FAIL_SLOW. However, if a +// pipeline is set to PIPELINE_FAILURE_POLICY_FAIL_FAST, it will stop scheduling +// any new tasks when a task has failed. Any scheduled tasks will continue to +// completion. +enum PipelineFailurePolicy { + // Default value, and follows fail slow behavior. + PIPELINE_FAILURE_POLICY_UNSPECIFIED = 0; + + // Indicates that the pipeline should continue to run until all possible + // tasks have been scheduled and completed. + PIPELINE_FAILURE_POLICY_FAIL_SLOW = 1; + + // Indicates that the pipeline should stop scheduling new tasks after a task + // has failed. + PIPELINE_FAILURE_POLICY_FAIL_FAST = 2; +} diff --git a/protos/google/cloud/aiplatform/v1/pipeline_job.proto b/protos/google/cloud/aiplatform/v1/pipeline_job.proto index 21f92926..eb12aabf 100644 --- a/protos/google/cloud/aiplatform/v1/pipeline_job.proto +++ b/protos/google/cloud/aiplatform/v1/pipeline_job.proto @@ -22,6 +22,7 @@ import "google/cloud/aiplatform/v1/artifact.proto"; import "google/cloud/aiplatform/v1/context.proto"; import "google/cloud/aiplatform/v1/encryption_spec.proto"; import "google/cloud/aiplatform/v1/execution.proto"; +import "google/cloud/aiplatform/v1/pipeline_failure_policy.proto"; import "google/cloud/aiplatform/v1/pipeline_state.proto"; import "google/cloud/aiplatform/v1/value.proto"; import "google/protobuf/struct.proto"; @@ -72,6 +73,14 @@ message PipelineJob { // `PipelineJob.pipeline_spec.schema_version` 2.1.0, such as pipelines built // using Kubeflow Pipelines SDK 1.9 or higher and the v2 DSL. map parameter_values = 3; + + // Represents the failure policy of a pipeline. Currently, the default of a + // pipeline is that the pipeline will continue to run until no more tasks + // can be executed, also known as PIPELINE_FAILURE_POLICY_FAIL_SLOW. + // However, if a pipeline is set to PIPELINE_FAILURE_POLICY_FAIL_FAST, it + // will stop scheduling any new tasks when a task has failed. Any scheduled + // tasks will continue to completion. + PipelineFailurePolicy failure_policy = 4; } // Output only. The resource name of the PipelineJob. @@ -150,6 +159,27 @@ message PipelineJob { string network = 18 [(google.api.resource_reference) = { type: "compute.googleapis.com/Network" }]; + + // A template uri from where the [PipelineJob.pipeline_spec][google.cloud.aiplatform.v1.PipelineJob.pipeline_spec], if empty, will + // be downloaded. + string template_uri = 19; + + // Output only. Pipeline template metadata. Will fill up fields if + // [PipelineJob.template_uri][google.cloud.aiplatform.v1.PipelineJob.template_uri] is from supported template registry. + PipelineTemplateMetadata template_metadata = 20 [(google.api.field_behavior) = OUTPUT_ONLY]; +} + +// Pipeline template metadata if [PipelineJob.template_uri][google.cloud.aiplatform.v1.PipelineJob.template_uri] is from supported +// template registry. Currently, the only supported registry is Artifact +// Registry. +message PipelineTemplateMetadata { + // The version_name in artifact registry. + // + // Will always be presented in output if the [PipelineJob.template_uri][google.cloud.aiplatform.v1.PipelineJob.template_uri] is + // from supported template registry. + // + // Format is "sha256:abcdef123456...". + string version = 3; } // The runtime detail of PipelineJob. diff --git a/protos/google/cloud/aiplatform/v1/pipeline_service.proto b/protos/google/cloud/aiplatform/v1/pipeline_service.proto index d749ecc8..fa6c5bf1 100644 --- a/protos/google/cloud/aiplatform/v1/pipeline_service.proto +++ b/protos/google/cloud/aiplatform/v1/pipeline_service.proto @@ -323,7 +323,7 @@ message ListPipelineJobsRequest { // Values must be in RFC 3339 format. // * `labels`: Supports key-value equality and key presence. // * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - // * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + // * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` // wildcard. // // Filter expressions can be combined together using logical operators diff --git a/protos/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto b/protos/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto index b50a8feb..5c0ade66 100644 --- a/protos/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto +++ b/protos/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto @@ -159,6 +159,9 @@ message BatchPredictionJob { // Starting this job has no impact on any existing deployments of the Model // and their resources. // Exactly one of model and unmanaged_container_model must be set. + // + // The model resource name may contain version id or version alias to specify + // the version, if no version is specified, the default version will be used. string model = 3 [(google.api.resource_reference) = { type: "aiplatform.googleapis.com/Model" }]; diff --git a/protos/google/cloud/aiplatform/v1beta1/completion_stats.proto b/protos/google/cloud/aiplatform/v1beta1/completion_stats.proto index 7d539d82..f784eda4 100644 --- a/protos/google/cloud/aiplatform/v1beta1/completion_stats.proto +++ b/protos/google/cloud/aiplatform/v1beta1/completion_stats.proto @@ -41,4 +41,8 @@ message CompletionStats { // Set to -1 if the number is unknown (for example, the operation failed // before the total entity number could be collected). int64 incomplete_count = 3 [(google.api.field_behavior) = OUTPUT_ONLY]; + + // Output only. The number of the successful forecast points that are generated by the + // forecasting model. This is ONLY used by the forecasting batch prediction. + int64 successful_forecast_point_count = 5 [(google.api.field_behavior) = OUTPUT_ONLY]; } diff --git a/protos/google/cloud/aiplatform/v1beta1/endpoint.proto b/protos/google/cloud/aiplatform/v1beta1/endpoint.proto index b2d12694..11e10251 100644 --- a/protos/google/cloud/aiplatform/v1beta1/endpoint.proto +++ b/protos/google/cloud/aiplatform/v1beta1/endpoint.proto @@ -154,8 +154,11 @@ message DeployedModel { // This value should be 1-10 characters, and valid characters are /[0-9]/. string id = 1 [(google.api.field_behavior) = IMMUTABLE]; - // Required. The name of the Model that this is the deployment of. Note that the Model - // may be in a different location than the DeployedModel's Endpoint. + // Required. The resource name of the Model that this is the deployment of. Note that + // the Model may be in a different location than the DeployedModel's Endpoint. + // + // The resource name may contain version id or version alias to specify the + // version, if no version is specified, the default version will be deployed. string model = 2 [ (google.api.field_behavior) = REQUIRED, (google.api.resource_reference) = { diff --git a/protos/google/cloud/aiplatform/v1beta1/explanation.proto b/protos/google/cloud/aiplatform/v1beta1/explanation.proto index 11e4c6c5..9f844d53 100644 --- a/protos/google/cloud/aiplatform/v1beta1/explanation.proto +++ b/protos/google/cloud/aiplatform/v1beta1/explanation.proto @@ -395,7 +395,7 @@ message Examples { // Preset config based on the desired query speed-precision trade-off // and modality - Preset preset = 4; + Presets presets = 4; } // The Cloud Storage location for the input instances. @@ -406,7 +406,7 @@ message Examples { } // Preset configuration for example-based explanations -message Preset { +message Presets { // Preset option controlling parameters for query speed-precision trade-off enum Query { // More precise neighbors as a trade-off against slower response. diff --git a/protos/google/cloud/aiplatform/v1beta1/featurestore_online_service.proto b/protos/google/cloud/aiplatform/v1beta1/featurestore_online_service.proto index a8c5e991..02417d11 100644 --- a/protos/google/cloud/aiplatform/v1beta1/featurestore_online_service.proto +++ b/protos/google/cloud/aiplatform/v1beta1/featurestore_online_service.proto @@ -171,7 +171,6 @@ message StreamingReadFeatureValuesRequest { } // Value for a feature. -// (-- NEXT ID: 15 --) message FeatureValue { // Metadata of feature value. message Metadata { diff --git a/protos/google/cloud/aiplatform/v1beta1/manual_batch_tuning_parameters.proto b/protos/google/cloud/aiplatform/v1beta1/manual_batch_tuning_parameters.proto index f8f75fdc..5498d89d 100644 --- a/protos/google/cloud/aiplatform/v1beta1/manual_batch_tuning_parameters.proto +++ b/protos/google/cloud/aiplatform/v1beta1/manual_batch_tuning_parameters.proto @@ -34,6 +34,6 @@ message ManualBatchTuningParameters { // speeds up the batch operation's execution, but too high value will result // in a whole batch not fitting in a machine's memory, and the whole // operation will fail. - // The default value is 4. + // The default value is 64. int32 batch_size = 1 [(google.api.field_behavior) = IMMUTABLE]; } diff --git a/protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto b/protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto index 49676251..ed3d04a9 100644 --- a/protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto +++ b/protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto @@ -55,6 +55,8 @@ message ModelMonitoringObjectiveConfig { // // "csv" // The source file is a CSV file. + // "jsonl" + // The source file is a JSONL file. string data_format = 2; // The target field name the model is to predict. diff --git a/protos/google/cloud/aiplatform/v1beta1/model_service.proto b/protos/google/cloud/aiplatform/v1beta1/model_service.proto index 273718e0..177e39c7 100644 --- a/protos/google/cloud/aiplatform/v1beta1/model_service.proto +++ b/protos/google/cloud/aiplatform/v1beta1/model_service.proto @@ -88,7 +88,7 @@ service ModelService { option (google.api.method_signature) = "model,update_mask"; } - // Incremental update the dataset used for a examples model. + // Incrementally update the dataset used for an examples model. rpc UpdateExplanationDataset(UpdateExplanationDatasetRequest) returns (google.longrunning.Operation) { option (google.api.http) = { post: "/v1beta1/{model=projects/*/locations/*/models/*}:updateExplanationDataset" @@ -250,9 +250,9 @@ message GetModelRequest { // // In order to retrieve a specific version of the model, also provide // the version ID or version alias. - // Example: projects/{project}/locations/{location}/models/{model}@2 + // Example: `projects/{project}/locations/{location}/models/{model}@2` // or - // projects/{project}/locations/{location}/models/{model}@golden + // `projects/{project}/locations/{location}/models/{model}@golden` // If no version ID or alias is specified, the "default" version will be // returned. The "default" version alias is created for the first version of // the model, and can be moved to other versions later on. There will be diff --git a/protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto b/protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto new file mode 100644 index 00000000..f197f510 --- /dev/null +++ b/protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto @@ -0,0 +1,44 @@ +// Copyright 2022 Google LLC +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +syntax = "proto3"; + +package google.cloud.aiplatform.v1beta1; + +option csharp_namespace = "Google.Cloud.AIPlatform.V1Beta1"; +option go_package = "google.golang.org/genproto/googleapis/cloud/aiplatform/v1beta1;aiplatform"; +option java_multiple_files = true; +option java_outer_classname = "PipelineFailurePolicyProto"; +option java_package = "com.google.cloud.aiplatform.v1beta1"; +option php_namespace = "Google\\Cloud\\AIPlatform\\V1beta1"; +option ruby_package = "Google::Cloud::AIPlatform::V1beta1"; + +// Represents the failure policy of a pipeline. Currently, the default of a +// pipeline is that the pipeline will continue to run until no more tasks can be +// executed, also known as PIPELINE_FAILURE_POLICY_FAIL_SLOW. However, if a +// pipeline is set to PIPELINE_FAILURE_POLICY_FAIL_FAST, it will stop scheduling +// any new tasks when a task has failed. Any scheduled tasks will continue to +// completion. +enum PipelineFailurePolicy { + // Default value, and follows fail slow behavior. + PIPELINE_FAILURE_POLICY_UNSPECIFIED = 0; + + // Indicates that the pipeline should continue to run until all possible + // tasks have been scheduled and completed. + PIPELINE_FAILURE_POLICY_FAIL_SLOW = 1; + + // Indicates that the pipeline should stop scheduling new tasks after a task + // has failed. + PIPELINE_FAILURE_POLICY_FAIL_FAST = 2; +} diff --git a/protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto b/protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto index 3e5b5ea0..9cb69a90 100644 --- a/protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto +++ b/protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto @@ -22,6 +22,7 @@ import "google/cloud/aiplatform/v1beta1/artifact.proto"; import "google/cloud/aiplatform/v1beta1/context.proto"; import "google/cloud/aiplatform/v1beta1/encryption_spec.proto"; import "google/cloud/aiplatform/v1beta1/execution.proto"; +import "google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto"; import "google/cloud/aiplatform/v1beta1/pipeline_state.proto"; import "google/cloud/aiplatform/v1beta1/value.proto"; import "google/protobuf/struct.proto"; @@ -72,6 +73,14 @@ message PipelineJob { // `PipelineJob.pipeline_spec.schema_version` 2.1.0, such as pipelines built // using Kubeflow Pipelines SDK 1.9 or higher and the v2 DSL. map parameter_values = 3; + + // Represents the failure policy of a pipeline. Currently, the default of a + // pipeline is that the pipeline will continue to run until no more tasks + // can be executed, also known as PIPELINE_FAILURE_POLICY_FAIL_SLOW. + // However, if a pipeline is set to PIPELINE_FAILURE_POLICY_FAIL_FAST, it + // will stop scheduling any new tasks when a task has failed. Any scheduled + // tasks will continue to completion. + PipelineFailurePolicy failure_policy = 4; } // Output only. The resource name of the PipelineJob. diff --git a/protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto b/protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto index 56123e65..43ad4038 100644 --- a/protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto +++ b/protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto @@ -323,7 +323,7 @@ message ListPipelineJobsRequest { // Values must be in RFC 3339 format. // * `labels`: Supports key-value equality and key presence. // * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - // * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + // * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` // wildcard. // // Filter expressions can be combined together using logical operators diff --git a/protos/protos.d.ts b/protos/protos.d.ts index e696d548..f317e206 100644 --- a/protos/protos.d.ts +++ b/protos/protos.d.ts @@ -2775,6 +2775,9 @@ export namespace google { /** ExplanationMetadata featureAttributionsSchemaUri */ featureAttributionsSchemaUri?: (string|null); + + /** ExplanationMetadata latentSpaceSource */ + latentSpaceSource?: (string|null); } /** Represents an ExplanationMetadata. */ @@ -2795,6 +2798,9 @@ export namespace google { /** ExplanationMetadata featureAttributionsSchemaUri. */ public featureAttributionsSchemaUri: string; + /** ExplanationMetadata latentSpaceSource. */ + public latentSpaceSource: string; + /** * Creates a new ExplanationMetadata instance using the specified properties. * @param [properties] Properties to set @@ -13677,6 +13683,9 @@ export namespace google { /** OnlineServingConfig fixedNodeCount */ fixedNodeCount?: (number|null); + + /** OnlineServingConfig scaling */ + scaling?: (google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling|null); } /** Represents an OnlineServingConfig. */ @@ -13691,6 +13700,9 @@ export namespace google { /** OnlineServingConfig fixedNodeCount. */ public fixedNodeCount: number; + /** OnlineServingConfig scaling. */ + public scaling?: (google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling|null); + /** * Creates a new OnlineServingConfig instance using the specified properties. * @param [properties] Properties to set @@ -13762,6 +13774,105 @@ export namespace google { public toJSON(): { [k: string]: any }; } + namespace OnlineServingConfig { + + /** Properties of a Scaling. */ + interface IScaling { + + /** Scaling minNodeCount */ + minNodeCount?: (number|null); + + /** Scaling maxNodeCount */ + maxNodeCount?: (number|null); + } + + /** Represents a Scaling. */ + class Scaling implements IScaling { + + /** + * Constructs a new Scaling. + * @param [properties] Properties to set + */ + constructor(properties?: google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling); + + /** Scaling minNodeCount. */ + public minNodeCount: number; + + /** Scaling maxNodeCount. */ + public maxNodeCount: number; + + /** + * Creates a new Scaling instance using the specified properties. + * @param [properties] Properties to set + * @returns Scaling instance + */ + public static create(properties?: google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling): google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling; + + /** + * Encodes the specified Scaling message. Does not implicitly {@link google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.verify|verify} messages. + * @param message Scaling message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encode(message: google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Encodes the specified Scaling message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.verify|verify} messages. + * @param message Scaling message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encodeDelimited(message: google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Decodes a Scaling message from the specified reader or buffer. + * @param reader Reader or buffer to decode from + * @param [length] Message length if known beforehand + * @returns Scaling + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling; + + /** + * Decodes a Scaling message from the specified reader or buffer, length delimited. + * @param reader Reader or buffer to decode from + * @returns Scaling + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling; + + /** + * Verifies a Scaling message. + * @param message Plain object to verify + * @returns `null` if valid, otherwise the reason why it is not + */ + public static verify(message: { [k: string]: any }): (string|null); + + /** + * Creates a Scaling message from a plain object. Also converts values to their respective internal types. + * @param object Plain object + * @returns Scaling + */ + public static fromObject(object: { [k: string]: any }): google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling; + + /** + * Creates a plain object from a Scaling message. Also converts values to other types if specified. + * @param message Scaling + * @param [options] Conversion options + * @returns Plain object + */ + public static toObject(message: google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling, options?: $protobuf.IConversionOptions): { [k: string]: any }; + + /** + * Converts this Scaling to JSON. + * @returns JSON object + */ + public toJSON(): { [k: string]: any }; + } + } + /** State enum. */ enum State { STATE_UNSPECIFIED = 0, @@ -42265,6 +42376,13 @@ export namespace google { public toJSON(): { [k: string]: any }; } + /** PipelineFailurePolicy enum. */ + enum PipelineFailurePolicy { + PIPELINE_FAILURE_POLICY_UNSPECIFIED = 0, + PIPELINE_FAILURE_POLICY_FAIL_SLOW = 1, + PIPELINE_FAILURE_POLICY_FAIL_FAST = 2 + } + /** Properties of a PipelineJob. */ interface IPipelineJob { @@ -42312,6 +42430,12 @@ export namespace google { /** PipelineJob network */ network?: (string|null); + + /** PipelineJob templateUri */ + templateUri?: (string|null); + + /** PipelineJob templateMetadata */ + templateMetadata?: (google.cloud.aiplatform.v1.IPipelineTemplateMetadata|null); } /** Represents a PipelineJob. */ @@ -42368,6 +42492,12 @@ export namespace google { /** PipelineJob network. */ public network: string; + /** PipelineJob templateUri. */ + public templateUri: string; + + /** PipelineJob templateMetadata. */ + public templateMetadata?: (google.cloud.aiplatform.v1.IPipelineTemplateMetadata|null); + /** * Creates a new PipelineJob instance using the specified properties. * @param [properties] Properties to set @@ -42452,6 +42582,9 @@ export namespace google { /** RuntimeConfig parameterValues */ parameterValues?: ({ [k: string]: google.protobuf.IValue }|null); + + /** RuntimeConfig failurePolicy */ + failurePolicy?: (google.cloud.aiplatform.v1.PipelineFailurePolicy|keyof typeof google.cloud.aiplatform.v1.PipelineFailurePolicy|null); } /** Represents a RuntimeConfig. */ @@ -42472,6 +42605,9 @@ export namespace google { /** RuntimeConfig parameterValues. */ public parameterValues: { [k: string]: google.protobuf.IValue }; + /** RuntimeConfig failurePolicy. */ + public failurePolicy: (google.cloud.aiplatform.v1.PipelineFailurePolicy|keyof typeof google.cloud.aiplatform.v1.PipelineFailurePolicy); + /** * Creates a new RuntimeConfig instance using the specified properties. * @param [properties] Properties to set @@ -42544,6 +42680,96 @@ export namespace google { } } + /** Properties of a PipelineTemplateMetadata. */ + interface IPipelineTemplateMetadata { + + /** PipelineTemplateMetadata version */ + version?: (string|null); + } + + /** Represents a PipelineTemplateMetadata. */ + class PipelineTemplateMetadata implements IPipelineTemplateMetadata { + + /** + * Constructs a new PipelineTemplateMetadata. + * @param [properties] Properties to set + */ + constructor(properties?: google.cloud.aiplatform.v1.IPipelineTemplateMetadata); + + /** PipelineTemplateMetadata version. */ + public version: string; + + /** + * Creates a new PipelineTemplateMetadata instance using the specified properties. + * @param [properties] Properties to set + * @returns PipelineTemplateMetadata instance + */ + public static create(properties?: google.cloud.aiplatform.v1.IPipelineTemplateMetadata): google.cloud.aiplatform.v1.PipelineTemplateMetadata; + + /** + * Encodes the specified PipelineTemplateMetadata message. Does not implicitly {@link google.cloud.aiplatform.v1.PipelineTemplateMetadata.verify|verify} messages. + * @param message PipelineTemplateMetadata message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encode(message: google.cloud.aiplatform.v1.IPipelineTemplateMetadata, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Encodes the specified PipelineTemplateMetadata message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1.PipelineTemplateMetadata.verify|verify} messages. + * @param message PipelineTemplateMetadata message or plain object to encode + * @param [writer] Writer to encode to + * @returns Writer + */ + public static encodeDelimited(message: google.cloud.aiplatform.v1.IPipelineTemplateMetadata, writer?: $protobuf.Writer): $protobuf.Writer; + + /** + * Decodes a PipelineTemplateMetadata message from the specified reader or buffer. + * @param reader Reader or buffer to decode from + * @param [length] Message length if known beforehand + * @returns PipelineTemplateMetadata + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.cloud.aiplatform.v1.PipelineTemplateMetadata; + + /** + * Decodes a PipelineTemplateMetadata message from the specified reader or buffer, length delimited. + * @param reader Reader or buffer to decode from + * @returns PipelineTemplateMetadata + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.cloud.aiplatform.v1.PipelineTemplateMetadata; + + /** + * Verifies a PipelineTemplateMetadata message. + * @param message Plain object to verify + * @returns `null` if valid, otherwise the reason why it is not + */ + public static verify(message: { [k: string]: any }): (string|null); + + /** + * Creates a PipelineTemplateMetadata message from a plain object. Also converts values to their respective internal types. + * @param object Plain object + * @returns PipelineTemplateMetadata + */ + public static fromObject(object: { [k: string]: any }): google.cloud.aiplatform.v1.PipelineTemplateMetadata; + + /** + * Creates a plain object from a PipelineTemplateMetadata message. Also converts values to other types if specified. + * @param message PipelineTemplateMetadata + * @param [options] Conversion options + * @returns Plain object + */ + public static toObject(message: google.cloud.aiplatform.v1.PipelineTemplateMetadata, options?: $protobuf.IConversionOptions): { [k: string]: any }; + + /** + * Converts this PipelineTemplateMetadata to JSON. + * @returns JSON object + */ + public toJSON(): { [k: string]: any }; + } + /** Properties of a PipelineJobDetail. */ interface IPipelineJobDetail { @@ -62833,6 +63059,9 @@ export namespace google { /** CompletionStats incompleteCount */ incompleteCount?: (number|Long|string|null); + + /** CompletionStats successfulForecastPointCount */ + successfulForecastPointCount?: (number|Long|string|null); } /** Represents a CompletionStats. */ @@ -62853,6 +63082,9 @@ export namespace google { /** CompletionStats incompleteCount. */ public incompleteCount: (number|Long|string); + /** CompletionStats successfulForecastPointCount. */ + public successfulForecastPointCount: (number|Long|string); + /** * Creates a new CompletionStats instance using the specified properties. * @param [properties] Properties to set @@ -64325,8 +64557,8 @@ export namespace google { /** Examples nearestNeighborSearchConfig */ nearestNeighborSearchConfig?: (google.protobuf.IValue|null); - /** Examples preset */ - preset?: (google.cloud.aiplatform.v1beta1.IPreset|null); + /** Examples presets */ + presets?: (google.cloud.aiplatform.v1beta1.IPresets|null); /** Examples gcsSource */ gcsSource?: (google.cloud.aiplatform.v1beta1.IGcsSource|null); @@ -64347,8 +64579,8 @@ export namespace google { /** Examples nearestNeighborSearchConfig. */ public nearestNeighborSearchConfig?: (google.protobuf.IValue|null); - /** Examples preset. */ - public preset?: (google.cloud.aiplatform.v1beta1.IPreset|null); + /** Examples presets. */ + public presets?: (google.cloud.aiplatform.v1beta1.IPresets|null); /** Examples gcsSource. */ public gcsSource?: (google.cloud.aiplatform.v1beta1.IGcsSource|null); @@ -64357,7 +64589,7 @@ export namespace google { public neighborCount: number; /** Examples config. */ - public config?: ("nearestNeighborSearchConfig"|"preset"); + public config?: ("nearestNeighborSearchConfig"|"presets"); /** * Creates a new Examples instance using the specified properties. @@ -64430,106 +64662,106 @@ export namespace google { public toJSON(): { [k: string]: any }; } - /** Properties of a Preset. */ - interface IPreset { + /** Properties of a Presets. */ + interface IPresets { - /** Preset query */ - query?: (google.cloud.aiplatform.v1beta1.Preset.Query|keyof typeof google.cloud.aiplatform.v1beta1.Preset.Query|null); + /** Presets query */ + query?: (google.cloud.aiplatform.v1beta1.Presets.Query|keyof typeof google.cloud.aiplatform.v1beta1.Presets.Query|null); - /** Preset modality */ - modality?: (google.cloud.aiplatform.v1beta1.Preset.Modality|keyof typeof google.cloud.aiplatform.v1beta1.Preset.Modality|null); + /** Presets modality */ + modality?: (google.cloud.aiplatform.v1beta1.Presets.Modality|keyof typeof google.cloud.aiplatform.v1beta1.Presets.Modality|null); } - /** Represents a Preset. */ - class Preset implements IPreset { + /** Represents a Presets. */ + class Presets implements IPresets { /** - * Constructs a new Preset. + * Constructs a new Presets. * @param [properties] Properties to set */ - constructor(properties?: google.cloud.aiplatform.v1beta1.IPreset); + constructor(properties?: google.cloud.aiplatform.v1beta1.IPresets); - /** Preset query. */ - public query?: (google.cloud.aiplatform.v1beta1.Preset.Query|keyof typeof google.cloud.aiplatform.v1beta1.Preset.Query|null); + /** Presets query. */ + public query?: (google.cloud.aiplatform.v1beta1.Presets.Query|keyof typeof google.cloud.aiplatform.v1beta1.Presets.Query|null); - /** Preset modality. */ - public modality: (google.cloud.aiplatform.v1beta1.Preset.Modality|keyof typeof google.cloud.aiplatform.v1beta1.Preset.Modality); + /** Presets modality. */ + public modality: (google.cloud.aiplatform.v1beta1.Presets.Modality|keyof typeof google.cloud.aiplatform.v1beta1.Presets.Modality); - /** Preset _query. */ + /** Presets _query. */ public _query?: "query"; /** - * Creates a new Preset instance using the specified properties. + * Creates a new Presets instance using the specified properties. * @param [properties] Properties to set - * @returns Preset instance + * @returns Presets instance */ - public static create(properties?: google.cloud.aiplatform.v1beta1.IPreset): google.cloud.aiplatform.v1beta1.Preset; + public static create(properties?: google.cloud.aiplatform.v1beta1.IPresets): google.cloud.aiplatform.v1beta1.Presets; /** - * Encodes the specified Preset message. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Preset.verify|verify} messages. - * @param message Preset message or plain object to encode + * Encodes the specified Presets message. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Presets.verify|verify} messages. + * @param message Presets message or plain object to encode * @param [writer] Writer to encode to * @returns Writer */ - public static encode(message: google.cloud.aiplatform.v1beta1.IPreset, writer?: $protobuf.Writer): $protobuf.Writer; + public static encode(message: google.cloud.aiplatform.v1beta1.IPresets, writer?: $protobuf.Writer): $protobuf.Writer; /** - * Encodes the specified Preset message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Preset.verify|verify} messages. - * @param message Preset message or plain object to encode + * Encodes the specified Presets message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Presets.verify|verify} messages. + * @param message Presets message or plain object to encode * @param [writer] Writer to encode to * @returns Writer */ - public static encodeDelimited(message: google.cloud.aiplatform.v1beta1.IPreset, writer?: $protobuf.Writer): $protobuf.Writer; + public static encodeDelimited(message: google.cloud.aiplatform.v1beta1.IPresets, writer?: $protobuf.Writer): $protobuf.Writer; /** - * Decodes a Preset message from the specified reader or buffer. + * Decodes a Presets message from the specified reader or buffer. * @param reader Reader or buffer to decode from * @param [length] Message length if known beforehand - * @returns Preset + * @returns Presets * @throws {Error} If the payload is not a reader or valid buffer * @throws {$protobuf.util.ProtocolError} If required fields are missing */ - public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.cloud.aiplatform.v1beta1.Preset; + public static decode(reader: ($protobuf.Reader|Uint8Array), length?: number): google.cloud.aiplatform.v1beta1.Presets; /** - * Decodes a Preset message from the specified reader or buffer, length delimited. + * Decodes a Presets message from the specified reader or buffer, length delimited. * @param reader Reader or buffer to decode from - * @returns Preset + * @returns Presets * @throws {Error} If the payload is not a reader or valid buffer * @throws {$protobuf.util.ProtocolError} If required fields are missing */ - public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.cloud.aiplatform.v1beta1.Preset; + public static decodeDelimited(reader: ($protobuf.Reader|Uint8Array)): google.cloud.aiplatform.v1beta1.Presets; /** - * Verifies a Preset message. + * Verifies a Presets message. * @param message Plain object to verify * @returns `null` if valid, otherwise the reason why it is not */ public static verify(message: { [k: string]: any }): (string|null); /** - * Creates a Preset message from a plain object. Also converts values to their respective internal types. + * Creates a Presets message from a plain object. Also converts values to their respective internal types. * @param object Plain object - * @returns Preset + * @returns Presets */ - public static fromObject(object: { [k: string]: any }): google.cloud.aiplatform.v1beta1.Preset; + public static fromObject(object: { [k: string]: any }): google.cloud.aiplatform.v1beta1.Presets; /** - * Creates a plain object from a Preset message. Also converts values to other types if specified. - * @param message Preset + * Creates a plain object from a Presets message. Also converts values to other types if specified. + * @param message Presets * @param [options] Conversion options * @returns Plain object */ - public static toObject(message: google.cloud.aiplatform.v1beta1.Preset, options?: $protobuf.IConversionOptions): { [k: string]: any }; + public static toObject(message: google.cloud.aiplatform.v1beta1.Presets, options?: $protobuf.IConversionOptions): { [k: string]: any }; /** - * Converts this Preset to JSON. + * Converts this Presets to JSON. * @returns JSON object */ public toJSON(): { [k: string]: any }; } - namespace Preset { + namespace Presets { /** Query enum. */ enum Query { @@ -105575,6 +105807,13 @@ export namespace google { public toJSON(): { [k: string]: any }; } + /** PipelineFailurePolicy enum. */ + enum PipelineFailurePolicy { + PIPELINE_FAILURE_POLICY_UNSPECIFIED = 0, + PIPELINE_FAILURE_POLICY_FAIL_SLOW = 1, + PIPELINE_FAILURE_POLICY_FAIL_FAST = 2 + } + /** Properties of a PipelineJob. */ interface IPipelineJob { @@ -105774,6 +106013,9 @@ export namespace google { /** RuntimeConfig parameterValues */ parameterValues?: ({ [k: string]: google.protobuf.IValue }|null); + + /** RuntimeConfig failurePolicy */ + failurePolicy?: (google.cloud.aiplatform.v1beta1.PipelineFailurePolicy|keyof typeof google.cloud.aiplatform.v1beta1.PipelineFailurePolicy|null); } /** Represents a RuntimeConfig. */ @@ -105794,6 +106036,9 @@ export namespace google { /** RuntimeConfig parameterValues. */ public parameterValues: { [k: string]: google.protobuf.IValue }; + /** RuntimeConfig failurePolicy. */ + public failurePolicy: (google.cloud.aiplatform.v1beta1.PipelineFailurePolicy|keyof typeof google.cloud.aiplatform.v1beta1.PipelineFailurePolicy); + /** * Creates a new RuntimeConfig instance using the specified properties. * @param [properties] Properties to set diff --git a/protos/protos.js b/protos/protos.js index d293feb3..2246eceb 100644 --- a/protos/protos.js +++ b/protos/protos.js @@ -7190,6 +7190,7 @@ * @property {Object.|null} [inputs] ExplanationMetadata inputs * @property {Object.|null} [outputs] ExplanationMetadata outputs * @property {string|null} [featureAttributionsSchemaUri] ExplanationMetadata featureAttributionsSchemaUri + * @property {string|null} [latentSpaceSource] ExplanationMetadata latentSpaceSource */ /** @@ -7233,6 +7234,14 @@ */ ExplanationMetadata.prototype.featureAttributionsSchemaUri = ""; + /** + * ExplanationMetadata latentSpaceSource. + * @member {string} latentSpaceSource + * @memberof google.cloud.aiplatform.v1.ExplanationMetadata + * @instance + */ + ExplanationMetadata.prototype.latentSpaceSource = ""; + /** * Creates a new ExplanationMetadata instance using the specified properties. * @function create @@ -7269,6 +7278,8 @@ } if (message.featureAttributionsSchemaUri != null && Object.hasOwnProperty.call(message, "featureAttributionsSchemaUri")) writer.uint32(/* id 3, wireType 2 =*/26).string(message.featureAttributionsSchemaUri); + if (message.latentSpaceSource != null && Object.hasOwnProperty.call(message, "latentSpaceSource")) + writer.uint32(/* id 5, wireType 2 =*/42).string(message.latentSpaceSource); return writer; }; @@ -7350,6 +7361,9 @@ case 3: message.featureAttributionsSchemaUri = reader.string(); break; + case 5: + message.latentSpaceSource = reader.string(); + break; default: reader.skipType(tag & 7); break; @@ -7408,6 +7422,9 @@ if (message.featureAttributionsSchemaUri != null && message.hasOwnProperty("featureAttributionsSchemaUri")) if (!$util.isString(message.featureAttributionsSchemaUri)) return "featureAttributionsSchemaUri: string expected"; + if (message.latentSpaceSource != null && message.hasOwnProperty("latentSpaceSource")) + if (!$util.isString(message.latentSpaceSource)) + return "latentSpaceSource: string expected"; return null; }; @@ -7445,6 +7462,8 @@ } if (object.featureAttributionsSchemaUri != null) message.featureAttributionsSchemaUri = String(object.featureAttributionsSchemaUri); + if (object.latentSpaceSource != null) + message.latentSpaceSource = String(object.latentSpaceSource); return message; }; @@ -7465,8 +7484,10 @@ object.inputs = {}; object.outputs = {}; } - if (options.defaults) + if (options.defaults) { object.featureAttributionsSchemaUri = ""; + object.latentSpaceSource = ""; + } var keys2; if (message.inputs && (keys2 = Object.keys(message.inputs)).length) { object.inputs = {}; @@ -7480,6 +7501,8 @@ } if (message.featureAttributionsSchemaUri != null && message.hasOwnProperty("featureAttributionsSchemaUri")) object.featureAttributionsSchemaUri = message.featureAttributionsSchemaUri; + if (message.latentSpaceSource != null && message.hasOwnProperty("latentSpaceSource")) + object.latentSpaceSource = message.latentSpaceSource; return object; }; @@ -34854,6 +34877,7 @@ * @memberof google.cloud.aiplatform.v1.Featurestore * @interface IOnlineServingConfig * @property {number|null} [fixedNodeCount] OnlineServingConfig fixedNodeCount + * @property {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling|null} [scaling] OnlineServingConfig scaling */ /** @@ -34879,6 +34903,14 @@ */ OnlineServingConfig.prototype.fixedNodeCount = 0; + /** + * OnlineServingConfig scaling. + * @member {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling|null|undefined} scaling + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig + * @instance + */ + OnlineServingConfig.prototype.scaling = null; + /** * Creates a new OnlineServingConfig instance using the specified properties. * @function create @@ -34905,6 +34937,8 @@ writer = $Writer.create(); if (message.fixedNodeCount != null && Object.hasOwnProperty.call(message, "fixedNodeCount")) writer.uint32(/* id 2, wireType 0 =*/16).int32(message.fixedNodeCount); + if (message.scaling != null && Object.hasOwnProperty.call(message, "scaling")) + $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.encode(message.scaling, writer.uint32(/* id 4, wireType 2 =*/34).fork()).ldelim(); return writer; }; @@ -34942,6 +34976,9 @@ case 2: message.fixedNodeCount = reader.int32(); break; + case 4: + message.scaling = $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.decode(reader, reader.uint32()); + break; default: reader.skipType(tag & 7); break; @@ -34980,6 +35017,11 @@ if (message.fixedNodeCount != null && message.hasOwnProperty("fixedNodeCount")) if (!$util.isInteger(message.fixedNodeCount)) return "fixedNodeCount: integer expected"; + if (message.scaling != null && message.hasOwnProperty("scaling")) { + var error = $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.verify(message.scaling); + if (error) + return "scaling." + error; + } return null; }; @@ -34997,6 +35039,11 @@ var message = new $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig(); if (object.fixedNodeCount != null) message.fixedNodeCount = object.fixedNodeCount | 0; + if (object.scaling != null) { + if (typeof object.scaling !== "object") + throw TypeError(".google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.scaling: object expected"); + message.scaling = $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.fromObject(object.scaling); + } return message; }; @@ -35013,10 +35060,14 @@ if (!options) options = {}; var object = {}; - if (options.defaults) + if (options.defaults) { object.fixedNodeCount = 0; + object.scaling = null; + } if (message.fixedNodeCount != null && message.hasOwnProperty("fixedNodeCount")) object.fixedNodeCount = message.fixedNodeCount; + if (message.scaling != null && message.hasOwnProperty("scaling")) + object.scaling = $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.toObject(message.scaling, options); return object; }; @@ -35031,6 +35082,216 @@ return this.constructor.toObject(this, $protobuf.util.toJSONOptions); }; + OnlineServingConfig.Scaling = (function() { + + /** + * Properties of a Scaling. + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig + * @interface IScaling + * @property {number|null} [minNodeCount] Scaling minNodeCount + * @property {number|null} [maxNodeCount] Scaling maxNodeCount + */ + + /** + * Constructs a new Scaling. + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig + * @classdesc Represents a Scaling. + * @implements IScaling + * @constructor + * @param {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling=} [properties] Properties to set + */ + function Scaling(properties) { + if (properties) + for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) + if (properties[keys[i]] != null) + this[keys[i]] = properties[keys[i]]; + } + + /** + * Scaling minNodeCount. + * @member {number} minNodeCount + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @instance + */ + Scaling.prototype.minNodeCount = 0; + + /** + * Scaling maxNodeCount. + * @member {number} maxNodeCount + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @instance + */ + Scaling.prototype.maxNodeCount = 0; + + /** + * Creates a new Scaling instance using the specified properties. + * @function create + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling=} [properties] Properties to set + * @returns {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling} Scaling instance + */ + Scaling.create = function create(properties) { + return new Scaling(properties); + }; + + /** + * Encodes the specified Scaling message. Does not implicitly {@link google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.verify|verify} messages. + * @function encode + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling} message Scaling message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + Scaling.encode = function encode(message, writer) { + if (!writer) + writer = $Writer.create(); + if (message.minNodeCount != null && Object.hasOwnProperty.call(message, "minNodeCount")) + writer.uint32(/* id 1, wireType 0 =*/8).int32(message.minNodeCount); + if (message.maxNodeCount != null && Object.hasOwnProperty.call(message, "maxNodeCount")) + writer.uint32(/* id 2, wireType 0 =*/16).int32(message.maxNodeCount); + return writer; + }; + + /** + * Encodes the specified Scaling message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling.verify|verify} messages. + * @function encodeDelimited + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.IScaling} message Scaling message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + Scaling.encodeDelimited = function encodeDelimited(message, writer) { + return this.encode(message, writer).ldelim(); + }; + + /** + * Decodes a Scaling message from the specified reader or buffer. + * @function decode + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @param {number} [length] Message length if known beforehand + * @returns {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling} Scaling + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + Scaling.decode = function decode(reader, length) { + if (!(reader instanceof $Reader)) + reader = $Reader.create(reader); + var end = length === undefined ? reader.len : reader.pos + length, message = new $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling(); + while (reader.pos < end) { + var tag = reader.uint32(); + switch (tag >>> 3) { + case 1: + message.minNodeCount = reader.int32(); + break; + case 2: + message.maxNodeCount = reader.int32(); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }; + + /** + * Decodes a Scaling message from the specified reader or buffer, length delimited. + * @function decodeDelimited + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @returns {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling} Scaling + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + Scaling.decodeDelimited = function decodeDelimited(reader) { + if (!(reader instanceof $Reader)) + reader = new $Reader(reader); + return this.decode(reader, reader.uint32()); + }; + + /** + * Verifies a Scaling message. + * @function verify + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {Object.} message Plain object to verify + * @returns {string|null} `null` if valid, otherwise the reason why it is not + */ + Scaling.verify = function verify(message) { + if (typeof message !== "object" || message === null) + return "object expected"; + if (message.minNodeCount != null && message.hasOwnProperty("minNodeCount")) + if (!$util.isInteger(message.minNodeCount)) + return "minNodeCount: integer expected"; + if (message.maxNodeCount != null && message.hasOwnProperty("maxNodeCount")) + if (!$util.isInteger(message.maxNodeCount)) + return "maxNodeCount: integer expected"; + return null; + }; + + /** + * Creates a Scaling message from a plain object. Also converts values to their respective internal types. + * @function fromObject + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {Object.} object Plain object + * @returns {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling} Scaling + */ + Scaling.fromObject = function fromObject(object) { + if (object instanceof $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling) + return object; + var message = new $root.google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling(); + if (object.minNodeCount != null) + message.minNodeCount = object.minNodeCount | 0; + if (object.maxNodeCount != null) + message.maxNodeCount = object.maxNodeCount | 0; + return message; + }; + + /** + * Creates a plain object from a Scaling message. Also converts values to other types if specified. + * @function toObject + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @static + * @param {google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling} message Scaling + * @param {$protobuf.IConversionOptions} [options] Conversion options + * @returns {Object.} Plain object + */ + Scaling.toObject = function toObject(message, options) { + if (!options) + options = {}; + var object = {}; + if (options.defaults) { + object.minNodeCount = 0; + object.maxNodeCount = 0; + } + if (message.minNodeCount != null && message.hasOwnProperty("minNodeCount")) + object.minNodeCount = message.minNodeCount; + if (message.maxNodeCount != null && message.hasOwnProperty("maxNodeCount")) + object.maxNodeCount = message.maxNodeCount; + return object; + }; + + /** + * Converts this Scaling to JSON. + * @function toJSON + * @memberof google.cloud.aiplatform.v1.Featurestore.OnlineServingConfig.Scaling + * @instance + * @returns {Object.} JSON object + */ + Scaling.prototype.toJSON = function toJSON() { + return this.constructor.toObject(this, $protobuf.util.toJSONOptions); + }; + + return Scaling; + })(); + return OnlineServingConfig; })(); @@ -101280,6 +101541,22 @@ return ListModelEvaluationSlicesResponse; })(); + /** + * PipelineFailurePolicy enum. + * @name google.cloud.aiplatform.v1.PipelineFailurePolicy + * @enum {number} + * @property {number} PIPELINE_FAILURE_POLICY_UNSPECIFIED=0 PIPELINE_FAILURE_POLICY_UNSPECIFIED value + * @property {number} PIPELINE_FAILURE_POLICY_FAIL_SLOW=1 PIPELINE_FAILURE_POLICY_FAIL_SLOW value + * @property {number} PIPELINE_FAILURE_POLICY_FAIL_FAST=2 PIPELINE_FAILURE_POLICY_FAIL_FAST value + */ + v1.PipelineFailurePolicy = (function() { + var valuesById = {}, values = Object.create(valuesById); + values[valuesById[0] = "PIPELINE_FAILURE_POLICY_UNSPECIFIED"] = 0; + values[valuesById[1] = "PIPELINE_FAILURE_POLICY_FAIL_SLOW"] = 1; + values[valuesById[2] = "PIPELINE_FAILURE_POLICY_FAIL_FAST"] = 2; + return values; + })(); + v1.PipelineJob = (function() { /** @@ -101301,6 +101578,8 @@ * @property {google.cloud.aiplatform.v1.IEncryptionSpec|null} [encryptionSpec] PipelineJob encryptionSpec * @property {string|null} [serviceAccount] PipelineJob serviceAccount * @property {string|null} [network] PipelineJob network + * @property {string|null} [templateUri] PipelineJob templateUri + * @property {google.cloud.aiplatform.v1.IPipelineTemplateMetadata|null} [templateMetadata] PipelineJob templateMetadata */ /** @@ -101439,6 +101718,22 @@ */ PipelineJob.prototype.network = ""; + /** + * PipelineJob templateUri. + * @member {string} templateUri + * @memberof google.cloud.aiplatform.v1.PipelineJob + * @instance + */ + PipelineJob.prototype.templateUri = ""; + + /** + * PipelineJob templateMetadata. + * @member {google.cloud.aiplatform.v1.IPipelineTemplateMetadata|null|undefined} templateMetadata + * @memberof google.cloud.aiplatform.v1.PipelineJob + * @instance + */ + PipelineJob.prototype.templateMetadata = null; + /** * Creates a new PipelineJob instance using the specified properties. * @function create @@ -101494,6 +101789,10 @@ writer.uint32(/* id 17, wireType 2 =*/138).string(message.serviceAccount); if (message.network != null && Object.hasOwnProperty.call(message, "network")) writer.uint32(/* id 18, wireType 2 =*/146).string(message.network); + if (message.templateUri != null && Object.hasOwnProperty.call(message, "templateUri")) + writer.uint32(/* id 19, wireType 2 =*/154).string(message.templateUri); + if (message.templateMetadata != null && Object.hasOwnProperty.call(message, "templateMetadata")) + $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata.encode(message.templateMetadata, writer.uint32(/* id 20, wireType 2 =*/162).fork()).ldelim(); return writer; }; @@ -101592,6 +101891,12 @@ case 18: message.network = reader.string(); break; + case 19: + message.templateUri = reader.string(); + break; + case 20: + message.templateMetadata = $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata.decode(reader, reader.uint32()); + break; default: reader.skipType(tag & 7); break; @@ -101707,6 +102012,14 @@ if (message.network != null && message.hasOwnProperty("network")) if (!$util.isString(message.network)) return "network: string expected"; + if (message.templateUri != null && message.hasOwnProperty("templateUri")) + if (!$util.isString(message.templateUri)) + return "templateUri: string expected"; + if (message.templateMetadata != null && message.hasOwnProperty("templateMetadata")) { + var error = $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata.verify(message.templateMetadata); + if (error) + return "templateMetadata." + error; + } return null; }; @@ -101820,6 +102133,13 @@ message.serviceAccount = String(object.serviceAccount); if (object.network != null) message.network = String(object.network); + if (object.templateUri != null) + message.templateUri = String(object.templateUri); + if (object.templateMetadata != null) { + if (typeof object.templateMetadata !== "object") + throw TypeError(".google.cloud.aiplatform.v1.PipelineJob.templateMetadata: object expected"); + message.templateMetadata = $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata.fromObject(object.templateMetadata); + } return message; }; @@ -101853,6 +102173,8 @@ object.encryptionSpec = null; object.serviceAccount = ""; object.network = ""; + object.templateUri = ""; + object.templateMetadata = null; } if (message.name != null && message.hasOwnProperty("name")) object.name = message.name; @@ -101888,6 +102210,10 @@ object.serviceAccount = message.serviceAccount; if (message.network != null && message.hasOwnProperty("network")) object.network = message.network; + if (message.templateUri != null && message.hasOwnProperty("templateUri")) + object.templateUri = message.templateUri; + if (message.templateMetadata != null && message.hasOwnProperty("templateMetadata")) + object.templateMetadata = $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata.toObject(message.templateMetadata, options); return object; }; @@ -101911,6 +102237,7 @@ * @property {Object.|null} [parameters] RuntimeConfig parameters * @property {string|null} [gcsOutputDirectory] RuntimeConfig gcsOutputDirectory * @property {Object.|null} [parameterValues] RuntimeConfig parameterValues + * @property {google.cloud.aiplatform.v1.PipelineFailurePolicy|null} [failurePolicy] RuntimeConfig failurePolicy */ /** @@ -101954,6 +102281,14 @@ */ RuntimeConfig.prototype.parameterValues = $util.emptyObject; + /** + * RuntimeConfig failurePolicy. + * @member {google.cloud.aiplatform.v1.PipelineFailurePolicy} failurePolicy + * @memberof google.cloud.aiplatform.v1.PipelineJob.RuntimeConfig + * @instance + */ + RuntimeConfig.prototype.failurePolicy = 0; + /** * Creates a new RuntimeConfig instance using the specified properties. * @function create @@ -101990,6 +102325,8 @@ writer.uint32(/* id 3, wireType 2 =*/26).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]); $root.google.protobuf.Value.encode(message.parameterValues[keys[i]], writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim().ldelim(); } + if (message.failurePolicy != null && Object.hasOwnProperty.call(message, "failurePolicy")) + writer.uint32(/* id 4, wireType 0 =*/32).int32(message.failurePolicy); return writer; }; @@ -102071,6 +102408,9 @@ } message.parameterValues[key] = value; break; + case 4: + message.failurePolicy = reader.int32(); + break; default: reader.skipType(tag & 7); break; @@ -102129,6 +102469,15 @@ return "parameterValues." + error; } } + if (message.failurePolicy != null && message.hasOwnProperty("failurePolicy")) + switch (message.failurePolicy) { + default: + return "failurePolicy: enum value expected"; + case 0: + case 1: + case 2: + break; + } return null; }; @@ -102166,6 +102515,20 @@ message.parameterValues[keys[i]] = $root.google.protobuf.Value.fromObject(object.parameterValues[keys[i]]); } } + switch (object.failurePolicy) { + case "PIPELINE_FAILURE_POLICY_UNSPECIFIED": + case 0: + message.failurePolicy = 0; + break; + case "PIPELINE_FAILURE_POLICY_FAIL_SLOW": + case 1: + message.failurePolicy = 1; + break; + case "PIPELINE_FAILURE_POLICY_FAIL_FAST": + case 2: + message.failurePolicy = 2; + break; + } return message; }; @@ -102186,8 +102549,10 @@ object.parameters = {}; object.parameterValues = {}; } - if (options.defaults) + if (options.defaults) { object.gcsOutputDirectory = ""; + object.failurePolicy = options.enums === String ? "PIPELINE_FAILURE_POLICY_UNSPECIFIED" : 0; + } var keys2; if (message.parameters && (keys2 = Object.keys(message.parameters)).length) { object.parameters = {}; @@ -102201,6 +102566,8 @@ for (var j = 0; j < keys2.length; ++j) object.parameterValues[keys2[j]] = $root.google.protobuf.Value.toObject(message.parameterValues[keys2[j]], options); } + if (message.failurePolicy != null && message.hasOwnProperty("failurePolicy")) + object.failurePolicy = options.enums === String ? $root.google.cloud.aiplatform.v1.PipelineFailurePolicy[message.failurePolicy] : message.failurePolicy; return object; }; @@ -102221,6 +102588,193 @@ return PipelineJob; })(); + v1.PipelineTemplateMetadata = (function() { + + /** + * Properties of a PipelineTemplateMetadata. + * @memberof google.cloud.aiplatform.v1 + * @interface IPipelineTemplateMetadata + * @property {string|null} [version] PipelineTemplateMetadata version + */ + + /** + * Constructs a new PipelineTemplateMetadata. + * @memberof google.cloud.aiplatform.v1 + * @classdesc Represents a PipelineTemplateMetadata. + * @implements IPipelineTemplateMetadata + * @constructor + * @param {google.cloud.aiplatform.v1.IPipelineTemplateMetadata=} [properties] Properties to set + */ + function PipelineTemplateMetadata(properties) { + if (properties) + for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) + if (properties[keys[i]] != null) + this[keys[i]] = properties[keys[i]]; + } + + /** + * PipelineTemplateMetadata version. + * @member {string} version + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @instance + */ + PipelineTemplateMetadata.prototype.version = ""; + + /** + * Creates a new PipelineTemplateMetadata instance using the specified properties. + * @function create + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {google.cloud.aiplatform.v1.IPipelineTemplateMetadata=} [properties] Properties to set + * @returns {google.cloud.aiplatform.v1.PipelineTemplateMetadata} PipelineTemplateMetadata instance + */ + PipelineTemplateMetadata.create = function create(properties) { + return new PipelineTemplateMetadata(properties); + }; + + /** + * Encodes the specified PipelineTemplateMetadata message. Does not implicitly {@link google.cloud.aiplatform.v1.PipelineTemplateMetadata.verify|verify} messages. + * @function encode + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {google.cloud.aiplatform.v1.IPipelineTemplateMetadata} message PipelineTemplateMetadata message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + PipelineTemplateMetadata.encode = function encode(message, writer) { + if (!writer) + writer = $Writer.create(); + if (message.version != null && Object.hasOwnProperty.call(message, "version")) + writer.uint32(/* id 3, wireType 2 =*/26).string(message.version); + return writer; + }; + + /** + * Encodes the specified PipelineTemplateMetadata message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1.PipelineTemplateMetadata.verify|verify} messages. + * @function encodeDelimited + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {google.cloud.aiplatform.v1.IPipelineTemplateMetadata} message PipelineTemplateMetadata message or plain object to encode + * @param {$protobuf.Writer} [writer] Writer to encode to + * @returns {$protobuf.Writer} Writer + */ + PipelineTemplateMetadata.encodeDelimited = function encodeDelimited(message, writer) { + return this.encode(message, writer).ldelim(); + }; + + /** + * Decodes a PipelineTemplateMetadata message from the specified reader or buffer. + * @function decode + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @param {number} [length] Message length if known beforehand + * @returns {google.cloud.aiplatform.v1.PipelineTemplateMetadata} PipelineTemplateMetadata + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + PipelineTemplateMetadata.decode = function decode(reader, length) { + if (!(reader instanceof $Reader)) + reader = $Reader.create(reader); + var end = length === undefined ? reader.len : reader.pos + length, message = new $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata(); + while (reader.pos < end) { + var tag = reader.uint32(); + switch (tag >>> 3) { + case 3: + message.version = reader.string(); + break; + default: + reader.skipType(tag & 7); + break; + } + } + return message; + }; + + /** + * Decodes a PipelineTemplateMetadata message from the specified reader or buffer, length delimited. + * @function decodeDelimited + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from + * @returns {google.cloud.aiplatform.v1.PipelineTemplateMetadata} PipelineTemplateMetadata + * @throws {Error} If the payload is not a reader or valid buffer + * @throws {$protobuf.util.ProtocolError} If required fields are missing + */ + PipelineTemplateMetadata.decodeDelimited = function decodeDelimited(reader) { + if (!(reader instanceof $Reader)) + reader = new $Reader(reader); + return this.decode(reader, reader.uint32()); + }; + + /** + * Verifies a PipelineTemplateMetadata message. + * @function verify + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {Object.} message Plain object to verify + * @returns {string|null} `null` if valid, otherwise the reason why it is not + */ + PipelineTemplateMetadata.verify = function verify(message) { + if (typeof message !== "object" || message === null) + return "object expected"; + if (message.version != null && message.hasOwnProperty("version")) + if (!$util.isString(message.version)) + return "version: string expected"; + return null; + }; + + /** + * Creates a PipelineTemplateMetadata message from a plain object. Also converts values to their respective internal types. + * @function fromObject + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {Object.} object Plain object + * @returns {google.cloud.aiplatform.v1.PipelineTemplateMetadata} PipelineTemplateMetadata + */ + PipelineTemplateMetadata.fromObject = function fromObject(object) { + if (object instanceof $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata) + return object; + var message = new $root.google.cloud.aiplatform.v1.PipelineTemplateMetadata(); + if (object.version != null) + message.version = String(object.version); + return message; + }; + + /** + * Creates a plain object from a PipelineTemplateMetadata message. Also converts values to other types if specified. + * @function toObject + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @static + * @param {google.cloud.aiplatform.v1.PipelineTemplateMetadata} message PipelineTemplateMetadata + * @param {$protobuf.IConversionOptions} [options] Conversion options + * @returns {Object.} Plain object + */ + PipelineTemplateMetadata.toObject = function toObject(message, options) { + if (!options) + options = {}; + var object = {}; + if (options.defaults) + object.version = ""; + if (message.version != null && message.hasOwnProperty("version")) + object.version = message.version; + return object; + }; + + /** + * Converts this PipelineTemplateMetadata to JSON. + * @function toJSON + * @memberof google.cloud.aiplatform.v1.PipelineTemplateMetadata + * @instance + * @returns {Object.} JSON object + */ + PipelineTemplateMetadata.prototype.toJSON = function toJSON() { + return this.constructor.toObject(this, $protobuf.util.toJSONOptions); + }; + + return PipelineTemplateMetadata; + })(); + v1.PipelineJobDetail = (function() { /** @@ -150249,6 +150803,7 @@ * @property {number|Long|null} [successfulCount] CompletionStats successfulCount * @property {number|Long|null} [failedCount] CompletionStats failedCount * @property {number|Long|null} [incompleteCount] CompletionStats incompleteCount + * @property {number|Long|null} [successfulForecastPointCount] CompletionStats successfulForecastPointCount */ /** @@ -150290,6 +150845,14 @@ */ CompletionStats.prototype.incompleteCount = $util.Long ? $util.Long.fromBits(0,0,false) : 0; + /** + * CompletionStats successfulForecastPointCount. + * @member {number|Long} successfulForecastPointCount + * @memberof google.cloud.aiplatform.v1beta1.CompletionStats + * @instance + */ + CompletionStats.prototype.successfulForecastPointCount = $util.Long ? $util.Long.fromBits(0,0,false) : 0; + /** * Creates a new CompletionStats instance using the specified properties. * @function create @@ -150320,6 +150883,8 @@ writer.uint32(/* id 2, wireType 0 =*/16).int64(message.failedCount); if (message.incompleteCount != null && Object.hasOwnProperty.call(message, "incompleteCount")) writer.uint32(/* id 3, wireType 0 =*/24).int64(message.incompleteCount); + if (message.successfulForecastPointCount != null && Object.hasOwnProperty.call(message, "successfulForecastPointCount")) + writer.uint32(/* id 5, wireType 0 =*/40).int64(message.successfulForecastPointCount); return writer; }; @@ -150363,6 +150928,9 @@ case 3: message.incompleteCount = reader.int64(); break; + case 5: + message.successfulForecastPointCount = reader.int64(); + break; default: reader.skipType(tag & 7); break; @@ -150407,6 +150975,9 @@ if (message.incompleteCount != null && message.hasOwnProperty("incompleteCount")) if (!$util.isInteger(message.incompleteCount) && !(message.incompleteCount && $util.isInteger(message.incompleteCount.low) && $util.isInteger(message.incompleteCount.high))) return "incompleteCount: integer|Long expected"; + if (message.successfulForecastPointCount != null && message.hasOwnProperty("successfulForecastPointCount")) + if (!$util.isInteger(message.successfulForecastPointCount) && !(message.successfulForecastPointCount && $util.isInteger(message.successfulForecastPointCount.low) && $util.isInteger(message.successfulForecastPointCount.high))) + return "successfulForecastPointCount: integer|Long expected"; return null; }; @@ -150449,6 +151020,15 @@ message.incompleteCount = object.incompleteCount; else if (typeof object.incompleteCount === "object") message.incompleteCount = new $util.LongBits(object.incompleteCount.low >>> 0, object.incompleteCount.high >>> 0).toNumber(); + if (object.successfulForecastPointCount != null) + if ($util.Long) + (message.successfulForecastPointCount = $util.Long.fromValue(object.successfulForecastPointCount)).unsigned = false; + else if (typeof object.successfulForecastPointCount === "string") + message.successfulForecastPointCount = parseInt(object.successfulForecastPointCount, 10); + else if (typeof object.successfulForecastPointCount === "number") + message.successfulForecastPointCount = object.successfulForecastPointCount; + else if (typeof object.successfulForecastPointCount === "object") + message.successfulForecastPointCount = new $util.LongBits(object.successfulForecastPointCount.low >>> 0, object.successfulForecastPointCount.high >>> 0).toNumber(); return message; }; @@ -150481,6 +151061,11 @@ object.incompleteCount = options.longs === String ? long.toString() : options.longs === Number ? long.toNumber() : long; } else object.incompleteCount = options.longs === String ? "0" : 0; + if ($util.Long) { + var long = new $util.Long(0, 0, false); + object.successfulForecastPointCount = options.longs === String ? long.toString() : options.longs === Number ? long.toNumber() : long; + } else + object.successfulForecastPointCount = options.longs === String ? "0" : 0; } if (message.successfulCount != null && message.hasOwnProperty("successfulCount")) if (typeof message.successfulCount === "number") @@ -150497,6 +151082,11 @@ object.incompleteCount = options.longs === String ? String(message.incompleteCount) : message.incompleteCount; else object.incompleteCount = options.longs === String ? $util.Long.prototype.toString.call(message.incompleteCount) : options.longs === Number ? new $util.LongBits(message.incompleteCount.low >>> 0, message.incompleteCount.high >>> 0).toNumber() : message.incompleteCount; + if (message.successfulForecastPointCount != null && message.hasOwnProperty("successfulForecastPointCount")) + if (typeof message.successfulForecastPointCount === "number") + object.successfulForecastPointCount = options.longs === String ? String(message.successfulForecastPointCount) : message.successfulForecastPointCount; + else + object.successfulForecastPointCount = options.longs === String ? $util.Long.prototype.toString.call(message.successfulForecastPointCount) : options.longs === Number ? new $util.LongBits(message.successfulForecastPointCount.low >>> 0, message.successfulForecastPointCount.high >>> 0).toNumber() : message.successfulForecastPointCount; return object; }; @@ -153850,7 +154440,7 @@ * @memberof google.cloud.aiplatform.v1beta1 * @interface IExamples * @property {google.protobuf.IValue|null} [nearestNeighborSearchConfig] Examples nearestNeighborSearchConfig - * @property {google.cloud.aiplatform.v1beta1.IPreset|null} [preset] Examples preset + * @property {google.cloud.aiplatform.v1beta1.IPresets|null} [presets] Examples presets * @property {google.cloud.aiplatform.v1beta1.IGcsSource|null} [gcsSource] Examples gcsSource * @property {number|null} [neighborCount] Examples neighborCount */ @@ -153879,12 +154469,12 @@ Examples.prototype.nearestNeighborSearchConfig = null; /** - * Examples preset. - * @member {google.cloud.aiplatform.v1beta1.IPreset|null|undefined} preset + * Examples presets. + * @member {google.cloud.aiplatform.v1beta1.IPresets|null|undefined} presets * @memberof google.cloud.aiplatform.v1beta1.Examples * @instance */ - Examples.prototype.preset = null; + Examples.prototype.presets = null; /** * Examples gcsSource. @@ -153907,12 +154497,12 @@ /** * Examples config. - * @member {"nearestNeighborSearchConfig"|"preset"|undefined} config + * @member {"nearestNeighborSearchConfig"|"presets"|undefined} config * @memberof google.cloud.aiplatform.v1beta1.Examples * @instance */ Object.defineProperty(Examples.prototype, "config", { - get: $util.oneOfGetter($oneOfFields = ["nearestNeighborSearchConfig", "preset"]), + get: $util.oneOfGetter($oneOfFields = ["nearestNeighborSearchConfig", "presets"]), set: $util.oneOfSetter($oneOfFields) }); @@ -153946,8 +154536,8 @@ $root.google.protobuf.Value.encode(message.nearestNeighborSearchConfig, writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim(); if (message.neighborCount != null && Object.hasOwnProperty.call(message, "neighborCount")) writer.uint32(/* id 3, wireType 0 =*/24).int32(message.neighborCount); - if (message.preset != null && Object.hasOwnProperty.call(message, "preset")) - $root.google.cloud.aiplatform.v1beta1.Preset.encode(message.preset, writer.uint32(/* id 4, wireType 2 =*/34).fork()).ldelim(); + if (message.presets != null && Object.hasOwnProperty.call(message, "presets")) + $root.google.cloud.aiplatform.v1beta1.Presets.encode(message.presets, writer.uint32(/* id 4, wireType 2 =*/34).fork()).ldelim(); return writer; }; @@ -153986,7 +154576,7 @@ message.nearestNeighborSearchConfig = $root.google.protobuf.Value.decode(reader, reader.uint32()); break; case 4: - message.preset = $root.google.cloud.aiplatform.v1beta1.Preset.decode(reader, reader.uint32()); + message.presets = $root.google.cloud.aiplatform.v1beta1.Presets.decode(reader, reader.uint32()); break; case 1: message.gcsSource = $root.google.cloud.aiplatform.v1beta1.GcsSource.decode(reader, reader.uint32()); @@ -154038,14 +154628,14 @@ return "nearestNeighborSearchConfig." + error; } } - if (message.preset != null && message.hasOwnProperty("preset")) { + if (message.presets != null && message.hasOwnProperty("presets")) { if (properties.config === 1) return "config: multiple values"; properties.config = 1; { - var error = $root.google.cloud.aiplatform.v1beta1.Preset.verify(message.preset); + var error = $root.google.cloud.aiplatform.v1beta1.Presets.verify(message.presets); if (error) - return "preset." + error; + return "presets." + error; } } if (message.gcsSource != null && message.hasOwnProperty("gcsSource")) { @@ -154076,10 +154666,10 @@ throw TypeError(".google.cloud.aiplatform.v1beta1.Examples.nearestNeighborSearchConfig: object expected"); message.nearestNeighborSearchConfig = $root.google.protobuf.Value.fromObject(object.nearestNeighborSearchConfig); } - if (object.preset != null) { - if (typeof object.preset !== "object") - throw TypeError(".google.cloud.aiplatform.v1beta1.Examples.preset: object expected"); - message.preset = $root.google.cloud.aiplatform.v1beta1.Preset.fromObject(object.preset); + if (object.presets != null) { + if (typeof object.presets !== "object") + throw TypeError(".google.cloud.aiplatform.v1beta1.Examples.presets: object expected"); + message.presets = $root.google.cloud.aiplatform.v1beta1.Presets.fromObject(object.presets); } if (object.gcsSource != null) { if (typeof object.gcsSource !== "object") @@ -154117,10 +154707,10 @@ } if (message.neighborCount != null && message.hasOwnProperty("neighborCount")) object.neighborCount = message.neighborCount; - if (message.preset != null && message.hasOwnProperty("preset")) { - object.preset = $root.google.cloud.aiplatform.v1beta1.Preset.toObject(message.preset, options); + if (message.presets != null && message.hasOwnProperty("presets")) { + object.presets = $root.google.cloud.aiplatform.v1beta1.Presets.toObject(message.presets, options); if (options.oneofs) - object.config = "preset"; + object.config = "presets"; } return object; }; @@ -154139,25 +154729,25 @@ return Examples; })(); - v1beta1.Preset = (function() { + v1beta1.Presets = (function() { /** - * Properties of a Preset. + * Properties of a Presets. * @memberof google.cloud.aiplatform.v1beta1 - * @interface IPreset - * @property {google.cloud.aiplatform.v1beta1.Preset.Query|null} [query] Preset query - * @property {google.cloud.aiplatform.v1beta1.Preset.Modality|null} [modality] Preset modality + * @interface IPresets + * @property {google.cloud.aiplatform.v1beta1.Presets.Query|null} [query] Presets query + * @property {google.cloud.aiplatform.v1beta1.Presets.Modality|null} [modality] Presets modality */ /** - * Constructs a new Preset. + * Constructs a new Presets. * @memberof google.cloud.aiplatform.v1beta1 - * @classdesc Represents a Preset. - * @implements IPreset + * @classdesc Represents a Presets. + * @implements IPresets * @constructor - * @param {google.cloud.aiplatform.v1beta1.IPreset=} [properties] Properties to set + * @param {google.cloud.aiplatform.v1beta1.IPresets=} [properties] Properties to set */ - function Preset(properties) { + function Presets(properties) { if (properties) for (var keys = Object.keys(properties), i = 0; i < keys.length; ++i) if (properties[keys[i]] != null) @@ -154165,57 +154755,57 @@ } /** - * Preset query. - * @member {google.cloud.aiplatform.v1beta1.Preset.Query|null|undefined} query - * @memberof google.cloud.aiplatform.v1beta1.Preset + * Presets query. + * @member {google.cloud.aiplatform.v1beta1.Presets.Query|null|undefined} query + * @memberof google.cloud.aiplatform.v1beta1.Presets * @instance */ - Preset.prototype.query = null; + Presets.prototype.query = null; /** - * Preset modality. - * @member {google.cloud.aiplatform.v1beta1.Preset.Modality} modality - * @memberof google.cloud.aiplatform.v1beta1.Preset + * Presets modality. + * @member {google.cloud.aiplatform.v1beta1.Presets.Modality} modality + * @memberof google.cloud.aiplatform.v1beta1.Presets * @instance */ - Preset.prototype.modality = 0; + Presets.prototype.modality = 0; // OneOf field names bound to virtual getters and setters var $oneOfFields; /** - * Preset _query. + * Presets _query. * @member {"query"|undefined} _query - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @instance */ - Object.defineProperty(Preset.prototype, "_query", { + Object.defineProperty(Presets.prototype, "_query", { get: $util.oneOfGetter($oneOfFields = ["query"]), set: $util.oneOfSetter($oneOfFields) }); /** - * Creates a new Preset instance using the specified properties. + * Creates a new Presets instance using the specified properties. * @function create - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static - * @param {google.cloud.aiplatform.v1beta1.IPreset=} [properties] Properties to set - * @returns {google.cloud.aiplatform.v1beta1.Preset} Preset instance + * @param {google.cloud.aiplatform.v1beta1.IPresets=} [properties] Properties to set + * @returns {google.cloud.aiplatform.v1beta1.Presets} Presets instance */ - Preset.create = function create(properties) { - return new Preset(properties); + Presets.create = function create(properties) { + return new Presets(properties); }; /** - * Encodes the specified Preset message. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Preset.verify|verify} messages. + * Encodes the specified Presets message. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Presets.verify|verify} messages. * @function encode - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static - * @param {google.cloud.aiplatform.v1beta1.IPreset} message Preset message or plain object to encode + * @param {google.cloud.aiplatform.v1beta1.IPresets} message Presets message or plain object to encode * @param {$protobuf.Writer} [writer] Writer to encode to * @returns {$protobuf.Writer} Writer */ - Preset.encode = function encode(message, writer) { + Presets.encode = function encode(message, writer) { if (!writer) writer = $Writer.create(); if (message.query != null && Object.hasOwnProperty.call(message, "query")) @@ -154226,33 +154816,33 @@ }; /** - * Encodes the specified Preset message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Preset.verify|verify} messages. + * Encodes the specified Presets message, length delimited. Does not implicitly {@link google.cloud.aiplatform.v1beta1.Presets.verify|verify} messages. * @function encodeDelimited - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static - * @param {google.cloud.aiplatform.v1beta1.IPreset} message Preset message or plain object to encode + * @param {google.cloud.aiplatform.v1beta1.IPresets} message Presets message or plain object to encode * @param {$protobuf.Writer} [writer] Writer to encode to * @returns {$protobuf.Writer} Writer */ - Preset.encodeDelimited = function encodeDelimited(message, writer) { + Presets.encodeDelimited = function encodeDelimited(message, writer) { return this.encode(message, writer).ldelim(); }; /** - * Decodes a Preset message from the specified reader or buffer. + * Decodes a Presets message from the specified reader or buffer. * @function decode - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from * @param {number} [length] Message length if known beforehand - * @returns {google.cloud.aiplatform.v1beta1.Preset} Preset + * @returns {google.cloud.aiplatform.v1beta1.Presets} Presets * @throws {Error} If the payload is not a reader or valid buffer * @throws {$protobuf.util.ProtocolError} If required fields are missing */ - Preset.decode = function decode(reader, length) { + Presets.decode = function decode(reader, length) { if (!(reader instanceof $Reader)) reader = $Reader.create(reader); - var end = length === undefined ? reader.len : reader.pos + length, message = new $root.google.cloud.aiplatform.v1beta1.Preset(); + var end = length === undefined ? reader.len : reader.pos + length, message = new $root.google.cloud.aiplatform.v1beta1.Presets(); while (reader.pos < end) { var tag = reader.uint32(); switch (tag >>> 3) { @@ -154271,30 +154861,30 @@ }; /** - * Decodes a Preset message from the specified reader or buffer, length delimited. + * Decodes a Presets message from the specified reader or buffer, length delimited. * @function decodeDelimited - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static * @param {$protobuf.Reader|Uint8Array} reader Reader or buffer to decode from - * @returns {google.cloud.aiplatform.v1beta1.Preset} Preset + * @returns {google.cloud.aiplatform.v1beta1.Presets} Presets * @throws {Error} If the payload is not a reader or valid buffer * @throws {$protobuf.util.ProtocolError} If required fields are missing */ - Preset.decodeDelimited = function decodeDelimited(reader) { + Presets.decodeDelimited = function decodeDelimited(reader) { if (!(reader instanceof $Reader)) reader = new $Reader(reader); return this.decode(reader, reader.uint32()); }; /** - * Verifies a Preset message. + * Verifies a Presets message. * @function verify - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static * @param {Object.} message Plain object to verify * @returns {string|null} `null` if valid, otherwise the reason why it is not */ - Preset.verify = function verify(message) { + Presets.verify = function verify(message) { if (typeof message !== "object" || message === null) return "object expected"; var properties = {}; @@ -154322,17 +154912,17 @@ }; /** - * Creates a Preset message from a plain object. Also converts values to their respective internal types. + * Creates a Presets message from a plain object. Also converts values to their respective internal types. * @function fromObject - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static * @param {Object.} object Plain object - * @returns {google.cloud.aiplatform.v1beta1.Preset} Preset + * @returns {google.cloud.aiplatform.v1beta1.Presets} Presets */ - Preset.fromObject = function fromObject(object) { - if (object instanceof $root.google.cloud.aiplatform.v1beta1.Preset) + Presets.fromObject = function fromObject(object) { + if (object instanceof $root.google.cloud.aiplatform.v1beta1.Presets) return object; - var message = new $root.google.cloud.aiplatform.v1beta1.Preset(); + var message = new $root.google.cloud.aiplatform.v1beta1.Presets(); switch (object.query) { case "PRECISE": case 0: @@ -154365,49 +154955,49 @@ }; /** - * Creates a plain object from a Preset message. Also converts values to other types if specified. + * Creates a plain object from a Presets message. Also converts values to other types if specified. * @function toObject - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @static - * @param {google.cloud.aiplatform.v1beta1.Preset} message Preset + * @param {google.cloud.aiplatform.v1beta1.Presets} message Presets * @param {$protobuf.IConversionOptions} [options] Conversion options * @returns {Object.} Plain object */ - Preset.toObject = function toObject(message, options) { + Presets.toObject = function toObject(message, options) { if (!options) options = {}; var object = {}; if (options.defaults) object.modality = options.enums === String ? "MODALITY_UNSPECIFIED" : 0; if (message.query != null && message.hasOwnProperty("query")) { - object.query = options.enums === String ? $root.google.cloud.aiplatform.v1beta1.Preset.Query[message.query] : message.query; + object.query = options.enums === String ? $root.google.cloud.aiplatform.v1beta1.Presets.Query[message.query] : message.query; if (options.oneofs) object._query = "query"; } if (message.modality != null && message.hasOwnProperty("modality")) - object.modality = options.enums === String ? $root.google.cloud.aiplatform.v1beta1.Preset.Modality[message.modality] : message.modality; + object.modality = options.enums === String ? $root.google.cloud.aiplatform.v1beta1.Presets.Modality[message.modality] : message.modality; return object; }; /** - * Converts this Preset to JSON. + * Converts this Presets to JSON. * @function toJSON - * @memberof google.cloud.aiplatform.v1beta1.Preset + * @memberof google.cloud.aiplatform.v1beta1.Presets * @instance * @returns {Object.} JSON object */ - Preset.prototype.toJSON = function toJSON() { + Presets.prototype.toJSON = function toJSON() { return this.constructor.toObject(this, $protobuf.util.toJSONOptions); }; /** * Query enum. - * @name google.cloud.aiplatform.v1beta1.Preset.Query + * @name google.cloud.aiplatform.v1beta1.Presets.Query * @enum {number} * @property {number} PRECISE=0 PRECISE value * @property {number} FAST=1 FAST value */ - Preset.Query = (function() { + Presets.Query = (function() { var valuesById = {}, values = Object.create(valuesById); values[valuesById[0] = "PRECISE"] = 0; values[valuesById[1] = "FAST"] = 1; @@ -154416,14 +155006,14 @@ /** * Modality enum. - * @name google.cloud.aiplatform.v1beta1.Preset.Modality + * @name google.cloud.aiplatform.v1beta1.Presets.Modality * @enum {number} * @property {number} MODALITY_UNSPECIFIED=0 MODALITY_UNSPECIFIED value * @property {number} IMAGE=1 IMAGE value * @property {number} TEXT=2 TEXT value * @property {number} TABULAR=3 TABULAR value */ - Preset.Modality = (function() { + Presets.Modality = (function() { var valuesById = {}, values = Object.create(valuesById); values[valuesById[0] = "MODALITY_UNSPECIFIED"] = 0; values[valuesById[1] = "IMAGE"] = 1; @@ -154432,7 +155022,7 @@ return values; })(); - return Preset; + return Presets; })(); v1beta1.ExplanationSpecOverride = (function() { @@ -252201,6 +252791,22 @@ return ListModelEvaluationSlicesResponse; })(); + /** + * PipelineFailurePolicy enum. + * @name google.cloud.aiplatform.v1beta1.PipelineFailurePolicy + * @enum {number} + * @property {number} PIPELINE_FAILURE_POLICY_UNSPECIFIED=0 PIPELINE_FAILURE_POLICY_UNSPECIFIED value + * @property {number} PIPELINE_FAILURE_POLICY_FAIL_SLOW=1 PIPELINE_FAILURE_POLICY_FAIL_SLOW value + * @property {number} PIPELINE_FAILURE_POLICY_FAIL_FAST=2 PIPELINE_FAILURE_POLICY_FAIL_FAST value + */ + v1beta1.PipelineFailurePolicy = (function() { + var valuesById = {}, values = Object.create(valuesById); + values[valuesById[0] = "PIPELINE_FAILURE_POLICY_UNSPECIFIED"] = 0; + values[valuesById[1] = "PIPELINE_FAILURE_POLICY_FAIL_SLOW"] = 1; + values[valuesById[2] = "PIPELINE_FAILURE_POLICY_FAIL_FAST"] = 2; + return values; + })(); + v1beta1.PipelineJob = (function() { /** @@ -252881,6 +253487,7 @@ * @property {Object.|null} [parameters] RuntimeConfig parameters * @property {string|null} [gcsOutputDirectory] RuntimeConfig gcsOutputDirectory * @property {Object.|null} [parameterValues] RuntimeConfig parameterValues + * @property {google.cloud.aiplatform.v1beta1.PipelineFailurePolicy|null} [failurePolicy] RuntimeConfig failurePolicy */ /** @@ -252924,6 +253531,14 @@ */ RuntimeConfig.prototype.parameterValues = $util.emptyObject; + /** + * RuntimeConfig failurePolicy. + * @member {google.cloud.aiplatform.v1beta1.PipelineFailurePolicy} failurePolicy + * @memberof google.cloud.aiplatform.v1beta1.PipelineJob.RuntimeConfig + * @instance + */ + RuntimeConfig.prototype.failurePolicy = 0; + /** * Creates a new RuntimeConfig instance using the specified properties. * @function create @@ -252960,6 +253575,8 @@ writer.uint32(/* id 3, wireType 2 =*/26).fork().uint32(/* id 1, wireType 2 =*/10).string(keys[i]); $root.google.protobuf.Value.encode(message.parameterValues[keys[i]], writer.uint32(/* id 2, wireType 2 =*/18).fork()).ldelim().ldelim(); } + if (message.failurePolicy != null && Object.hasOwnProperty.call(message, "failurePolicy")) + writer.uint32(/* id 4, wireType 0 =*/32).int32(message.failurePolicy); return writer; }; @@ -253041,6 +253658,9 @@ } message.parameterValues[key] = value; break; + case 4: + message.failurePolicy = reader.int32(); + break; default: reader.skipType(tag & 7); break; @@ -253099,6 +253719,15 @@ return "parameterValues." + error; } } + if (message.failurePolicy != null && message.hasOwnProperty("failurePolicy")) + switch (message.failurePolicy) { + default: + return "failurePolicy: enum value expected"; + case 0: + case 1: + case 2: + break; + } return null; }; @@ -253136,6 +253765,20 @@ message.parameterValues[keys[i]] = $root.google.protobuf.Value.fromObject(object.parameterValues[keys[i]]); } } + switch (object.failurePolicy) { + case "PIPELINE_FAILURE_POLICY_UNSPECIFIED": + case 0: + message.failurePolicy = 0; + break; + case "PIPELINE_FAILURE_POLICY_FAIL_SLOW": + case 1: + message.failurePolicy = 1; + break; + case "PIPELINE_FAILURE_POLICY_FAIL_FAST": + case 2: + message.failurePolicy = 2; + break; + } return message; }; @@ -253156,8 +253799,10 @@ object.parameters = {}; object.parameterValues = {}; } - if (options.defaults) + if (options.defaults) { object.gcsOutputDirectory = ""; + object.failurePolicy = options.enums === String ? "PIPELINE_FAILURE_POLICY_UNSPECIFIED" : 0; + } var keys2; if (message.parameters && (keys2 = Object.keys(message.parameters)).length) { object.parameters = {}; @@ -253171,6 +253816,8 @@ for (var j = 0; j < keys2.length; ++j) object.parameterValues[keys2[j]] = $root.google.protobuf.Value.toObject(message.parameterValues[keys2[j]], options); } + if (message.failurePolicy != null && message.hasOwnProperty("failurePolicy")) + object.failurePolicy = options.enums === String ? $root.google.cloud.aiplatform.v1beta1.PipelineFailurePolicy[message.failurePolicy] : message.failurePolicy; return object; }; diff --git a/protos/protos.json b/protos/protos.json index 8fb1a4fc..94abc9e3 100644 --- a/protos/protos.json +++ b/protos/protos.json @@ -803,6 +803,10 @@ "featureAttributionsSchemaUri": { "type": "string", "id": 3 + }, + "latentSpaceSource": { + "type": "string", + "id": 5 } }, "nested": { @@ -3950,6 +3954,27 @@ "fixedNodeCount": { "type": "int32", "id": 2 + }, + "scaling": { + "type": "Scaling", + "id": 4 + } + }, + "nested": { + "Scaling": { + "fields": { + "minNodeCount": { + "type": "int32", + "id": 1, + "options": { + "(google.api.field_behavior)": "REQUIRED" + } + }, + "maxNodeCount": { + "type": "int32", + "id": 2 + } + } } } }, @@ -11692,6 +11717,13 @@ } } }, + "PipelineFailurePolicy": { + "values": { + "PIPELINE_FAILURE_POLICY_UNSPECIFIED": 0, + "PIPELINE_FAILURE_POLICY_FAIL_SLOW": 1, + "PIPELINE_FAILURE_POLICY_FAIL_FAST": 2 + } + }, "PipelineJob": { "options": { "(google.api.resource).type": "aiplatform.googleapis.com/PipelineJob", @@ -11785,6 +11817,17 @@ "options": { "(google.api.resource_reference).type": "compute.googleapis.com/Network" } + }, + "templateUri": { + "type": "string", + "id": 19 + }, + "templateMetadata": { + "type": "PipelineTemplateMetadata", + "id": 20, + "options": { + "(google.api.field_behavior)": "OUTPUT_ONLY" + } } }, "nested": { @@ -11809,11 +11852,23 @@ "keyType": "string", "type": "google.protobuf.Value", "id": 3 + }, + "failurePolicy": { + "type": "PipelineFailurePolicy", + "id": 4 } } } } }, + "PipelineTemplateMetadata": { + "fields": { + "version": { + "type": "string", + "id": 3 + } + } + }, "PipelineJobDetail": { "fields": { "pipelineContext": { @@ -17121,6 +17176,13 @@ "options": { "(google.api.field_behavior)": "OUTPUT_ONLY" } + }, + "successfulForecastPointCount": { + "type": "int64", + "id": 5, + "options": { + "(google.api.field_behavior)": "OUTPUT_ONLY" + } } } }, @@ -17404,7 +17466,7 @@ "config": { "oneof": [ "nearestNeighborSearchConfig", - "preset" + "presets" ] } }, @@ -17413,8 +17475,8 @@ "type": "google.protobuf.Value", "id": 2 }, - "preset": { - "type": "Preset", + "presets": { + "type": "Presets", "id": 4 }, "gcsSource": { @@ -17427,7 +17489,7 @@ } } }, - "Preset": { + "Presets": { "oneofs": { "_query": { "oneof": [ @@ -28773,6 +28835,13 @@ } } }, + "PipelineFailurePolicy": { + "values": { + "PIPELINE_FAILURE_POLICY_UNSPECIFIED": 0, + "PIPELINE_FAILURE_POLICY_FAIL_SLOW": 1, + "PIPELINE_FAILURE_POLICY_FAIL_FAST": 2 + } + }, "PipelineJob": { "options": { "(google.api.resource).type": "aiplatform.googleapis.com/PipelineJob", @@ -28901,6 +28970,10 @@ "keyType": "string", "type": "google.protobuf.Value", "id": 3 + }, + "failurePolicy": { + "type": "PipelineFailurePolicy", + "id": 4 } } } diff --git a/samples/generated/v1/pipeline_service.list_pipeline_jobs.js b/samples/generated/v1/pipeline_service.list_pipeline_jobs.js index 415a6da8..7b1fdce1 100644 --- a/samples/generated/v1/pipeline_service.list_pipeline_jobs.js +++ b/samples/generated/v1/pipeline_service.list_pipeline_jobs.js @@ -47,7 +47,7 @@ function main(parent) { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * Filter expressions can be combined together using logical operators * (`AND` & `OR`). diff --git a/samples/generated/v1beta1/model_service.get_model.js b/samples/generated/v1beta1/model_service.get_model.js index e9c2de6e..189e9f87 100644 --- a/samples/generated/v1beta1/model_service.get_model.js +++ b/samples/generated/v1beta1/model_service.get_model.js @@ -30,9 +30,9 @@ function main(name) { * Format: `projects/{project}/locations/{location}/models/{model}` * In order to retrieve a specific version of the model, also provide * the version ID or version alias. - * Example: projects/{project}/locations/{location}/models/{model}@2 + * Example: `projects/{project}/locations/{location}/models/{model}@2` * or - * projects/{project}/locations/{location}/models/{model}@golden + * `projects/{project}/locations/{location}/models/{model}@golden` * If no version ID or alias is specified, the "default" version will be * returned. The "default" version alias is created for the first version of * the model, and can be moved to other versions later on. There will be diff --git a/samples/generated/v1beta1/pipeline_service.list_pipeline_jobs.js b/samples/generated/v1beta1/pipeline_service.list_pipeline_jobs.js index 9439da56..65c32c3c 100644 --- a/samples/generated/v1beta1/pipeline_service.list_pipeline_jobs.js +++ b/samples/generated/v1beta1/pipeline_service.list_pipeline_jobs.js @@ -47,7 +47,7 @@ function main(parent) { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * Filter expressions can be combined together using logical operators * (`AND` & `OR`). diff --git a/samples/generated/v1beta1/snippet_metadata.google.cloud.aiplatform.v1beta1.json b/samples/generated/v1beta1/snippet_metadata.google.cloud.aiplatform.v1beta1.json index b832c34f..51527c03 100644 --- a/samples/generated/v1beta1/snippet_metadata.google.cloud.aiplatform.v1beta1.json +++ b/samples/generated/v1beta1/snippet_metadata.google.cloud.aiplatform.v1beta1.json @@ -5531,7 +5531,7 @@ "regionTag": "aiplatform_v1beta1_generated_ModelService_UpdateExplanationDataset_async", "title": "DatasetService updateExplanationDataset Sample", "origin": "API_DEFINITION", - "description": " Incremental update the dataset used for a examples model.", + "description": " Incrementally update the dataset used for an examples model.", "canonical": true, "file": "model_service.update_explanation_dataset.js", "language": "JAVASCRIPT", diff --git a/src/v1/dataset_service_proto_list.json b/src/v1/dataset_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/dataset_service_proto_list.json +++ b/src/v1/dataset_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/endpoint_service_proto_list.json b/src/v1/endpoint_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/endpoint_service_proto_list.json +++ b/src/v1/endpoint_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/featurestore_online_serving_service_client.ts b/src/v1/featurestore_online_serving_service_client.ts index c43f9c2c..ce8fec9e 100644 --- a/src/v1/featurestore_online_serving_service_client.ts +++ b/src/v1/featurestore_online_serving_service_client.ts @@ -266,7 +266,8 @@ export class FeaturestoreOnlineServingServiceClient { // Provide descriptors for these. this.descriptors.stream = { streamingReadFeatureValues: new this._gaxModule.StreamDescriptor( - gax.StreamType.SERVER_STREAMING + gax.StreamType.SERVER_STREAMING, + opts.fallback === 'rest' ), }; diff --git a/src/v1/featurestore_online_serving_service_proto_list.json b/src/v1/featurestore_online_serving_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/featurestore_online_serving_service_proto_list.json +++ b/src/v1/featurestore_online_serving_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/featurestore_service_proto_list.json b/src/v1/featurestore_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/featurestore_service_proto_list.json +++ b/src/v1/featurestore_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/index_endpoint_service_proto_list.json b/src/v1/index_endpoint_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/index_endpoint_service_proto_list.json +++ b/src/v1/index_endpoint_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/index_service_proto_list.json b/src/v1/index_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/index_service_proto_list.json +++ b/src/v1/index_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/job_service_proto_list.json b/src/v1/job_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/job_service_proto_list.json +++ b/src/v1/job_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/metadata_service_proto_list.json b/src/v1/metadata_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/metadata_service_proto_list.json +++ b/src/v1/metadata_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/migration_service_proto_list.json b/src/v1/migration_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/migration_service_proto_list.json +++ b/src/v1/migration_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/model_service_proto_list.json b/src/v1/model_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/model_service_proto_list.json +++ b/src/v1/model_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/pipeline_service_client.ts b/src/v1/pipeline_service_client.ts index fbf03422..cae429fb 100644 --- a/src/v1/pipeline_service_client.ts +++ b/src/v1/pipeline_service_client.ts @@ -1646,7 +1646,7 @@ export class PipelineServiceClient { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * * Filter expressions can be combined together using logical operators @@ -1796,7 +1796,7 @@ export class PipelineServiceClient { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * * Filter expressions can be combined together using logical operators @@ -1894,7 +1894,7 @@ export class PipelineServiceClient { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * * Filter expressions can be combined together using logical operators diff --git a/src/v1/pipeline_service_proto_list.json b/src/v1/pipeline_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/pipeline_service_proto_list.json +++ b/src/v1/pipeline_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/prediction_service_proto_list.json b/src/v1/prediction_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/prediction_service_proto_list.json +++ b/src/v1/prediction_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/specialist_pool_service_proto_list.json b/src/v1/specialist_pool_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/specialist_pool_service_proto_list.json +++ b/src/v1/specialist_pool_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/tensorboard_service_client.ts b/src/v1/tensorboard_service_client.ts index 531caf0e..646a42dd 100644 --- a/src/v1/tensorboard_service_client.ts +++ b/src/v1/tensorboard_service_client.ts @@ -308,7 +308,8 @@ export class TensorboardServiceClient { // Provide descriptors for these. this.descriptors.stream = { readTensorboardBlobData: new this._gaxModule.StreamDescriptor( - gax.StreamType.SERVER_STREAMING + gax.StreamType.SERVER_STREAMING, + opts.fallback === 'rest' ), }; diff --git a/src/v1/tensorboard_service_proto_list.json b/src/v1/tensorboard_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/tensorboard_service_proto_list.json +++ b/src/v1/tensorboard_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1/vizier_service_proto_list.json b/src/v1/vizier_service_proto_list.json index 581a7346..68335b13 100644 --- a/src/v1/vizier_service_proto_list.json +++ b/src/v1/vizier_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1/model_service.proto", "../../protos/google/cloud/aiplatform/v1/operation.proto", + "../../protos/google/cloud/aiplatform/v1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1/pipeline_state.proto", diff --git a/src/v1beta1/dataset_service_proto_list.json b/src/v1beta1/dataset_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/dataset_service_proto_list.json +++ b/src/v1beta1/dataset_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/endpoint_service_proto_list.json b/src/v1beta1/endpoint_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/endpoint_service_proto_list.json +++ b/src/v1beta1/endpoint_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/featurestore_online_serving_service_client.ts b/src/v1beta1/featurestore_online_serving_service_client.ts index d8d31b56..4dc5a016 100644 --- a/src/v1beta1/featurestore_online_serving_service_client.ts +++ b/src/v1beta1/featurestore_online_serving_service_client.ts @@ -266,7 +266,8 @@ export class FeaturestoreOnlineServingServiceClient { // Provide descriptors for these. this.descriptors.stream = { streamingReadFeatureValues: new this._gaxModule.StreamDescriptor( - gax.StreamType.SERVER_STREAMING + gax.StreamType.SERVER_STREAMING, + opts.fallback === 'rest' ), }; diff --git a/src/v1beta1/featurestore_online_serving_service_proto_list.json b/src/v1beta1/featurestore_online_serving_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/featurestore_online_serving_service_proto_list.json +++ b/src/v1beta1/featurestore_online_serving_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/featurestore_service_proto_list.json b/src/v1beta1/featurestore_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/featurestore_service_proto_list.json +++ b/src/v1beta1/featurestore_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/index_endpoint_service_proto_list.json b/src/v1beta1/index_endpoint_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/index_endpoint_service_proto_list.json +++ b/src/v1beta1/index_endpoint_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/index_service_proto_list.json b/src/v1beta1/index_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/index_service_proto_list.json +++ b/src/v1beta1/index_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/job_service_proto_list.json b/src/v1beta1/job_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/job_service_proto_list.json +++ b/src/v1beta1/job_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/metadata_service_proto_list.json b/src/v1beta1/metadata_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/metadata_service_proto_list.json +++ b/src/v1beta1/metadata_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/migration_service_proto_list.json b/src/v1beta1/migration_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/migration_service_proto_list.json +++ b/src/v1beta1/migration_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/model_service_client.ts b/src/v1beta1/model_service_client.ts index a43309a4..7003e0c7 100644 --- a/src/v1beta1/model_service_client.ts +++ b/src/v1beta1/model_service_client.ts @@ -530,9 +530,9 @@ export class ModelServiceClient { * * In order to retrieve a specific version of the model, also provide * the version ID or version alias. - * Example: projects/{project}/locations/{location}/models/{model}@2 + * Example: `projects/{project}/locations/{location}/models/{model}@2` * or - * projects/{project}/locations/{location}/models/{model}@golden + * `projects/{project}/locations/{location}/models/{model}@golden` * If no version ID or alias is specified, the "default" version will be * returned. The "default" version alias is created for the first version of * the model, and can be moved to other versions later on. There will be @@ -1298,7 +1298,7 @@ export class ModelServiceClient { >; } /** - * Incremental update the dataset used for a examples model. + * Incrementally update the dataset used for an examples model. * * @param {Object} request * The request object that will be sent. diff --git a/src/v1beta1/model_service_proto_list.json b/src/v1beta1/model_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/model_service_proto_list.json +++ b/src/v1beta1/model_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/pipeline_service_client.ts b/src/v1beta1/pipeline_service_client.ts index 709268d7..fafe4982 100644 --- a/src/v1beta1/pipeline_service_client.ts +++ b/src/v1beta1/pipeline_service_client.ts @@ -1664,7 +1664,7 @@ export class PipelineServiceClient { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * * Filter expressions can be combined together using logical operators @@ -1814,7 +1814,7 @@ export class PipelineServiceClient { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * * Filter expressions can be combined together using logical operators @@ -1912,7 +1912,7 @@ export class PipelineServiceClient { * Values must be in RFC 3339 format. * * `labels`: Supports key-value equality and key presence. * * `template_uri`: Supports `=`, `!=` comparisons, and `:` wildcard. - * * `template_metadata.version_name`: Supports `=`, `!=` comparisons, and `:` + * * `template_metadata.version`: Supports `=`, `!=` comparisons, and `:` * wildcard. * * Filter expressions can be combined together using logical operators diff --git a/src/v1beta1/pipeline_service_proto_list.json b/src/v1beta1/pipeline_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/pipeline_service_proto_list.json +++ b/src/v1beta1/pipeline_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/prediction_service_proto_list.json b/src/v1beta1/prediction_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/prediction_service_proto_list.json +++ b/src/v1beta1/prediction_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/specialist_pool_service_proto_list.json b/src/v1beta1/specialist_pool_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/specialist_pool_service_proto_list.json +++ b/src/v1beta1/specialist_pool_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/tensorboard_service_client.ts b/src/v1beta1/tensorboard_service_client.ts index deea3568..61a4f5c9 100644 --- a/src/v1beta1/tensorboard_service_client.ts +++ b/src/v1beta1/tensorboard_service_client.ts @@ -308,7 +308,8 @@ export class TensorboardServiceClient { // Provide descriptors for these. this.descriptors.stream = { readTensorboardBlobData: new this._gaxModule.StreamDescriptor( - gax.StreamType.SERVER_STREAMING + gax.StreamType.SERVER_STREAMING, + opts.fallback === 'rest' ), }; diff --git a/src/v1beta1/tensorboard_service_proto_list.json b/src/v1beta1/tensorboard_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/tensorboard_service_proto_list.json +++ b/src/v1beta1/tensorboard_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto", diff --git a/src/v1beta1/vizier_service_proto_list.json b/src/v1beta1/vizier_service_proto_list.json index c916ab12..41d2bf4f 100644 --- a/src/v1beta1/vizier_service_proto_list.json +++ b/src/v1beta1/vizier_service_proto_list.json @@ -52,6 +52,7 @@ "../../protos/google/cloud/aiplatform/v1beta1/model_monitoring.proto", "../../protos/google/cloud/aiplatform/v1beta1/model_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/operation.proto", + "../../protos/google/cloud/aiplatform/v1beta1/pipeline_failure_policy.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_job.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_service.proto", "../../protos/google/cloud/aiplatform/v1beta1/pipeline_state.proto",