feat: add timestamp_outside_retention_rows_count to ImportFeatureValuesResponse and ImportFeatureValuesOperationMetadata in aiplatform v1 featurestore_service.proto

Google APIs · copybara-github · commit af65a1984fc9 · 2022-09-20T09:52:12.000-07:00
feat: add RemoveContextChildren rpc to aiplatform v1 metadata_service.proto
feat: add order_by to ListArtifactsRequest, ListContextsRequest, and ListExecutionsRequest in aiplatform v1 metadata_service.proto

PiperOrigin-RevId: 475580702
diff --git a/google/cloud/aiplatform/v1/batch_prediction_job.proto b/google/cloud/aiplatform/v1/batch_prediction_job.proto
@@ -154,7 +154,7 @@ message BatchPredictionJob {
   // Required. The user-defined name of this BatchPredictionJob.
   string display_name = 2 [(google.api.field_behavior) = REQUIRED];
 
-  // The name of the Model resoure that produces the predictions via this job,
+  // The name of the Model resource that produces the predictions via this job,
   // must share the same ancestor Location.
   // Starting this job has no impact on any existing deployments of the Model
   // and their resources.
diff --git a/google/cloud/aiplatform/v1/custom_job.proto b/google/cloud/aiplatform/v1/custom_job.proto
@@ -106,7 +106,6 @@ message CustomJob {
 }
 
 // Represents the spec of a CustomJob.
-// Next Id: 15
 message CustomJobSpec {
   // Required. The spec of the worker pools including machine type and Docker image.
   // All worker pools except the first one are optional and can be skipped by
diff --git a/google/cloud/aiplatform/v1/featurestore_service.proto b/google/cloud/aiplatform/v1/featurestore_service.proto
@@ -525,6 +525,10 @@ message ImportFeatureValuesResponse {
   // * Having a null timestamp.
   // * Not being parsable (applicable for CSV sources).
   int64 invalid_row_count = 6;
+
+  // The number rows that weren't ingested due to having feature timestamps
+  // outside the retention boundary.
+  int64 timestamp_outside_retention_rows_count = 4;
 }
 
 // Request message for [FeaturestoreService.BatchReadFeatureValues][google.cloud.aiplatform.v1.FeaturestoreService.BatchReadFeatureValues].
@@ -1193,6 +1197,10 @@ message ImportFeatureValuesOperationMetadata {
   // * Having a null timestamp.
   // * Not being parsable (applicable for CSV sources).
   int64 invalid_row_count = 6;
+
+  // The number rows that weren't ingested due to having timestamps outside the
+  // retention boundary.
+  int64 timestamp_outside_retention_rows_count = 7;
 }
 
 // Details of operations that exports Features values.
diff --git a/google/cloud/aiplatform/v1/job_service.proto b/google/cloud/aiplatform/v1/job_service.proto
@@ -388,13 +388,18 @@ message ListCustomJobsRequest {
   //   * `state` supports `=`, `!=` comparisons.
   //   * `create_time` supports `=`, `!=`,`<`, `<=`,`>`, `>=` comparisons.
   //     `create_time` must be in RFC 3339 format.
+  //   * `labels` supports general map functions that is:
+  //     `labels.key=value` - key:value equality
+  //     `labels.key:* - key existence
   //
   // Some examples of using the filter are:
   //
   //   * `state="JOB_STATE_SUCCEEDED" AND display_name:"my_job_*"`
   //   * `state!="JOB_STATE_FAILED" OR display_name="my_job"`
   //   * `NOT display_name="my_job"`
   //   * `create_time>"2021-05-18T00:00:00Z"`
+  //   * `labels.keyA=valueA`
+  //   * `labels.keyB:*`
   string filter = 2;
 
   // The standard list page size.
@@ -493,13 +498,18 @@ message ListDataLabelingJobsRequest {
   //   * `state` supports `=`, `!=` comparisons.
   //   * `create_time` supports `=`, `!=`,`<`, `<=`,`>`, `>=` comparisons.
   //     `create_time` must be in RFC 3339 format.
+  //   * `labels` supports general map functions that is:
+  //     `labels.key=value` - key:value equality
+  //     `labels.key:* - key existence
   //
   // Some examples of using the filter are:
   //
   //   * `state="JOB_STATE_SUCCEEDED" AND display_name:"my_job_*"`
   //   * `state!="JOB_STATE_FAILED" OR display_name="my_job"`
   //   * `NOT display_name="my_job"`
   //   * `create_time>"2021-05-18T00:00:00Z"`
+  //   * `labels.keyA=valueA`
+  //   * `labels.keyB:*`
   string filter = 2;
 
   // The standard list page size.
@@ -603,13 +613,18 @@ message ListHyperparameterTuningJobsRequest {
   //   * `state` supports `=`, `!=` comparisons.
   //   * `create_time` supports `=`, `!=`,`<`, `<=`,`>`, `>=` comparisons.
   //     `create_time` must be in RFC 3339 format.
+  //   * `labels` supports general map functions that is:
+  //     `labels.key=value` - key:value equality
+  //     `labels.key:* - key existence
   //
   // Some examples of using the filter are:
   //
   //   * `state="JOB_STATE_SUCCEEDED" AND display_name:"my_job_*"`
   //   * `state!="JOB_STATE_FAILED" OR display_name="my_job"`
   //   * `NOT display_name="my_job"`
   //   * `create_time>"2021-05-18T00:00:00Z"`
+  //   * `labels.keyA=valueA`
+  //   * `labels.keyB:*`
   string filter = 2;
 
   // The standard list page size.
@@ -711,13 +726,18 @@ message ListBatchPredictionJobsRequest {
   //   * `state` supports `=`, `!=` comparisons.
   //   * `create_time` supports `=`, `!=`,`<`, `<=`,`>`, `>=` comparisons.
   //     `create_time` must be in RFC 3339 format.
+  //   * `labels` supports general map functions that is:
+  //     `labels.key=value` - key:value equality
+  //     `labels.key:* - key existence
   //
   // Some examples of using the filter are:
   //
   //   * `state="JOB_STATE_SUCCEEDED" AND display_name:"my_job_*"`
   //   * `state!="JOB_STATE_FAILED" OR display_name="my_job"`
   //   * `NOT display_name="my_job"`
   //   * `create_time>"2021-05-18T00:00:00Z"`
+  //   * `labels.keyA=valueA`
+  //   * `labels.keyB:*`
   string filter = 2;
 
   // The standard list page size.
@@ -891,13 +911,18 @@ message ListModelDeploymentMonitoringJobsRequest {
   //   * `state` supports `=`, `!=` comparisons.
   //   * `create_time` supports `=`, `!=`,`<`, `<=`,`>`, `>=` comparisons.
   //     `create_time` must be in RFC 3339 format.
+  //   * `labels` supports general map functions that is:
+  //     `labels.key=value` - key:value equality
+  //     `labels.key:* - key existence
   //
   // Some examples of using the filter are:
   //
   //   * `state="JOB_STATE_SUCCEEDED" AND display_name:"my_job_*"`
   //   * `state!="JOB_STATE_FAILED" OR display_name="my_job"`
   //   * `NOT display_name="my_job"`
   //   * `create_time>"2021-05-18T00:00:00Z"`
+  //   * `labels.keyA=valueA`
+  //   * `labels.keyB:*`
   string filter = 2;
 
   // The standard list page size.
diff --git a/google/cloud/aiplatform/v1/metadata_service.proto b/google/cloud/aiplatform/v1/metadata_service.proto
@@ -228,6 +228,17 @@ service MetadataService {
     option (google.api.method_signature) = "context,child_contexts";
   }
 
+  // Remove a set of children contexts from a parent Context. If any of the
+  // child Contexts were NOT added to the parent Context, they are
+  // simply skipped.
+  rpc RemoveContextChildren(RemoveContextChildrenRequest) returns (RemoveContextChildrenResponse) {
+    option (google.api.http) = {
+      post: "/v1/{context=projects/*/locations/*/metadataStores/*/contexts/*}:removeContextChildren"
+      body: "*"
+    };
+    option (google.api.method_signature) = "context,child_contexts";
+  }
+
   // Retrieves Artifacts and Executions within the specified Context, connected
   // by Event edges and returned as a LineageSubgraph.
   rpc QueryContextLineageSubgraph(QueryContextLineageSubgraphRequest) returns (LineageSubgraph) {
@@ -549,6 +560,14 @@ message ListArtifactsRequest {
   //
   // For example: `display_name = "test" AND metadata.field1.bool_value = true`.
   string filter = 4;
+
+  // How the list of messages is ordered. Specify the values to order by and an
+  // ordering operation. The default sorting order is ascending. To specify
+  // descending order for a field, users append a " desc" suffix; for example:
+  // "foo desc, bar".
+  // Subfields are specified with a `.` character, such as foo.bar.
+  // see https://google.aip.dev/132#ordering for more details.
+  string order_by = 5;
 }
 
 // Response message for [MetadataService.ListArtifacts][google.cloud.aiplatform.v1.MetadataService.ListArtifacts].
@@ -735,6 +754,14 @@ message ListContextsRequest {
   //
   // For example: `display_name = "test" AND metadata.field1.bool_value = true`.
   string filter = 4;
+
+  // How the list of messages is ordered. Specify the values to order by and an
+  // ordering operation. The default sorting order is ascending. To specify
+  // descending order for a field, users append a " desc" suffix; for example:
+  // "foo desc, bar".
+  // Subfields are specified with a `.` character, such as foo.bar.
+  // see https://google.aip.dev/132#ordering for more details.
+  string order_by = 5;
 }
 
 // Response message for [MetadataService.ListContexts][google.cloud.aiplatform.v1.MetadataService.ListContexts].
@@ -890,6 +917,31 @@ message AddContextChildrenResponse {
 
 }
 
+// Request message for
+// [MetadataService.DeleteContextChildrenRequest][].
+message RemoveContextChildrenRequest {
+  // Required. The resource name of the parent Context.
+  //
+  // Format:
+  // `projects/{project}/locations/{location}/metadataStores/{metadatastore}/contexts/{context}`
+  string context = 1 [
+    (google.api.field_behavior) = REQUIRED,
+    (google.api.resource_reference) = {
+      type: "aiplatform.googleapis.com/Context"
+    }
+  ];
+
+  // The resource names of the child Contexts.
+  repeated string child_contexts = 2 [(google.api.resource_reference) = {
+                                        type: "aiplatform.googleapis.com/Context"
+                                      }];
+}
+
+// Response message for [MetadataService.RemoveContextChildren][google.cloud.aiplatform.v1.MetadataService.RemoveContextChildren].
+message RemoveContextChildrenResponse {
+
+}
+
 // Request message for [MetadataService.QueryContextLineageSubgraph][google.cloud.aiplatform.v1.MetadataService.QueryContextLineageSubgraph].
 message QueryContextLineageSubgraphRequest {
   // Required. The resource name of the Context whose Artifacts and Executions
@@ -999,6 +1051,14 @@ message ListExecutionsRequest {
   // logical operators (`AND` & `OR`).
   // For example: `display_name = "test" AND metadata.field1.bool_value = true`.
   string filter = 4;
+
+  // How the list of messages is ordered. Specify the values to order by and an
+  // ordering operation. The default sorting order is ascending. To specify
+  // descending order for a field, users append a " desc" suffix; for example:
+  // "foo desc, bar".
+  // Subfields are specified with a `.` character, such as foo.bar.
+  // see https://google.aip.dev/132#ordering for more details.
+  string order_by = 5;
 }
 
 // Response message for [MetadataService.ListExecutions][google.cloud.aiplatform.v1.MetadataService.ListExecutions].
diff --git a/google/cloud/aiplatform/v1/pipeline_service.proto b/google/cloud/aiplatform/v1/pipeline_service.proto
@@ -201,6 +201,9 @@ message ListTrainingPipelinesRequest {
   //   * `training_task_definition` `=`, `!=` comparisons, and `:` wildcard.
   //   * `create_time` supports `=`, `!=`,`<`, `<=`,`>`, `>=` comparisons.
   //     `create_time` must be in RFC 3339 format.
+  //   * `labels` supports general map functions that is:
+  //     `labels.key=value` - key:value equality
+  //     `labels.key:* - key existence
   //
   // Some examples of using the filter are:
   //

Original file line number	Diff line number	Diff line change
`@@ -106,7 +106,6 @@ message CustomJob {`
`106`	`106`	`}`
`107`	`107`
`108`	`108`	`// Represents the spec of a CustomJob.`
`109`		`-// Next Id: 15`
`110`	`109`	`message CustomJobSpec {`
`111`	`110`	`// Required. The spec of the worker pools including machine type and Docker image.`
`112`	`111`	`// All worker pools except the first one are optional and can be skipped by`