feat: add service_account to BatchPredictionJob in aiplatform v1beta1 batch_prediction_job.proto

protos/google/cloud/aiplatform/v1beta1/batch_prediction_job.proto

@@ -200,6 +200,15 @@ message BatchPredictionJob {
   // must be provided.
   BatchDedicatedResources dedicated_resources = 7;
 
+  // The service account that the DeployedModel's container runs as. If not
+  // specified, a system generated one will be used, which
+  // has minimal permissions and the custom container, if used, may not have
+  // enough permission to access other GCP resources.
+  //
+  // Users deploying the Model must have the `iam.serviceAccounts.actAs`
+  // permission on this service account.
+  string service_account = 29;
+
   // Immutable. Parameters configuring the batch behavior. Currently only applicable when
   // [dedicated_resources][google.cloud.aiplatform.v1beta1.BatchPredictionJob.dedicated_resources] are used (in other cases Vertex AI does
   // the tuning itself).

test/gapic_dataset_service_v1.ts

@@ -362,7 +362,6 @@ describe('v1.DatasetServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetDatasetRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getDataset(request), expectedError);
@@ -493,7 +492,6 @@ describe('v1.DatasetServiceClient', () => {
       );
       request.dataset = {};
       request.dataset.name = '';
-      const expectedHeaderRequestParams = 'dataset.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateDataset(request), expectedError);
@@ -620,7 +618,6 @@ describe('v1.DatasetServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetAnnotationSpecRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getAnnotationSpec(request), expectedError);

test/gapic_dataset_service_v1beta1.ts

@@ -362,7 +362,6 @@ describe('v1beta1.DatasetServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetDatasetRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getDataset(request), expectedError);
@@ -493,7 +492,6 @@ describe('v1beta1.DatasetServiceClient', () => {
       );
       request.dataset = {};
       request.dataset.name = '';
-      const expectedHeaderRequestParams = 'dataset.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateDataset(request), expectedError);
@@ -620,7 +618,6 @@ describe('v1beta1.DatasetServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetAnnotationSpecRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getAnnotationSpec(request), expectedError);

test/gapic_endpoint_service_v1.ts

@@ -362,7 +362,6 @@ describe('v1.EndpointServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetEndpointRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getEndpoint(request), expectedError);
@@ -493,7 +492,6 @@ describe('v1.EndpointServiceClient', () => {
       );
       request.endpoint = {};
       request.endpoint.name = '';
-      const expectedHeaderRequestParams = 'endpoint.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateEndpoint(request), expectedError);

test/gapic_endpoint_service_v1beta1.ts

@@ -362,7 +362,6 @@ describe('v1beta1.EndpointServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetEndpointRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getEndpoint(request), expectedError);
@@ -493,7 +492,6 @@ describe('v1beta1.EndpointServiceClient', () => {
       );
       request.endpoint = {};
       request.endpoint.name = '';
-      const expectedHeaderRequestParams = 'endpoint.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateEndpoint(request), expectedError);

test/gapic_featurestore_online_serving_service_v1.ts

@@ -325,7 +325,6 @@ describe('v1.FeaturestoreOnlineServingServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.ReadFeatureValuesRequest()
       );
       request.entityType = '';
-      const expectedHeaderRequestParams = 'entity_type=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.readFeatureValues(request), expectedError);
@@ -442,6 +441,7 @@ describe('v1.FeaturestoreOnlineServingServiceClient', () => {
       const request = generateSampleMessage(
         new protos.google.cloud.aiplatform.v1.StreamingReadFeatureValuesRequest()
       );
+      request.entityType = '';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       const stream = client.streamingReadFeatureValues(request);

test/gapic_featurestore_online_serving_service_v1beta1.ts

@@ -325,7 +325,6 @@ describe('v1beta1.FeaturestoreOnlineServingServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.ReadFeatureValuesRequest()
       );
       request.entityType = '';
-      const expectedHeaderRequestParams = 'entity_type=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.readFeatureValues(request), expectedError);
@@ -442,6 +441,7 @@ describe('v1beta1.FeaturestoreOnlineServingServiceClient', () => {
       const request = generateSampleMessage(
         new protos.google.cloud.aiplatform.v1beta1.StreamingReadFeatureValuesRequest()
       );
+      request.entityType = '';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       const stream = client.streamingReadFeatureValues(request);

test/gapic_featurestore_service_v1.ts

@@ -370,7 +370,6 @@ describe('v1.FeaturestoreServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetFeaturestoreRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getFeaturestore(request), expectedError);
@@ -505,7 +504,6 @@ describe('v1.FeaturestoreServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetEntityTypeRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getEntityType(request), expectedError);
@@ -644,7 +642,6 @@ describe('v1.FeaturestoreServiceClient', () => {
       );
       request.entityType = {};
       request.entityType.name = '';
-      const expectedHeaderRequestParams = 'entity_type.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateEntityType(request), expectedError);
@@ -779,7 +776,6 @@ describe('v1.FeaturestoreServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetFeatureRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getFeature(request), expectedError);
@@ -918,7 +914,6 @@ describe('v1.FeaturestoreServiceClient', () => {
       );
       request.feature = {};
       request.feature.name = '';
-      const expectedHeaderRequestParams = 'feature.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateFeature(request), expectedError);

test/gapic_featurestore_service_v1beta1.ts

@@ -374,7 +374,6 @@ describe('v1beta1.FeaturestoreServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetFeaturestoreRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getFeaturestore(request), expectedError);
@@ -505,7 +504,6 @@ describe('v1beta1.FeaturestoreServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetEntityTypeRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getEntityType(request), expectedError);
@@ -640,7 +638,6 @@ describe('v1beta1.FeaturestoreServiceClient', () => {
       );
       request.entityType = {};
       request.entityType.name = '';
-      const expectedHeaderRequestParams = 'entity_type.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateEntityType(request), expectedError);
@@ -771,7 +768,6 @@ describe('v1beta1.FeaturestoreServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetFeatureRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getFeature(request), expectedError);
@@ -906,7 +902,6 @@ describe('v1beta1.FeaturestoreServiceClient', () => {
       );
       request.feature = {};
       request.feature.name = '';
-      const expectedHeaderRequestParams = 'feature.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateFeature(request), expectedError);

test/gapic_index_endpoint_service_v1.ts

@@ -379,7 +379,6 @@ describe('v1.IndexEndpointServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetIndexEndpointRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getIndexEndpoint(request), expectedError);
@@ -515,7 +514,6 @@ describe('v1.IndexEndpointServiceClient', () => {
       );
       request.indexEndpoint = {};
       request.indexEndpoint.name = '';
-      const expectedHeaderRequestParams = 'index_endpoint.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateIndexEndpoint(request), expectedError);

test/gapic_index_endpoint_service_v1beta1.ts

@@ -374,7 +374,6 @@ describe('v1beta1.IndexEndpointServiceClient', () => {
         new protos.google.cloud.aiplatform.v1beta1.GetIndexEndpointRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getIndexEndpoint(request), expectedError);
@@ -510,7 +509,6 @@ describe('v1beta1.IndexEndpointServiceClient', () => {
       );
       request.indexEndpoint = {};
       request.indexEndpoint.name = '';
-      const expectedHeaderRequestParams = 'index_endpoint.name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateIndexEndpoint(request), expectedError);

test/gapic_index_service_v1.ts

@@ -357,7 +357,6 @@ describe('v1.IndexServiceClient', () => {
         new protos.google.cloud.aiplatform.v1.GetIndexRequest()
       );
       request.name = '';
-      const expectedHeaderRequestParams = 'name=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getIndex(request), expectedError);