feat: Add the ability to plumb environment capabilities through v1beta3 protos. (#53)

gcf-owl-bot[bot] · web-flow · commit 41c8fd603155 · 2022-03-16T18:53:18.000-07:00
* chore: update v2.14.2 gapic-generator-typescript Committer: @summer-ji-eng PiperOrigin-RevId: 434859890 Source-Link: googleapis/googleapis@bc2432d Source-Link: https://github.com/googleapis/googleapis-gen/commit/930b673103e92523f8cfed38decd7d3afae8ebe7 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOTMwYjY3MzEwM2U5MjUyM2Y4Y2ZlZDM4ZGVjZDdkM2FmYWU4ZWJlNyJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: Add the ability to plumb environment capabilities through v1beta3 protos. PiperOrigin-RevId: 434899727 Source-Link: googleapis/googleapis@392ae91 Source-Link: https://github.com/googleapis/googleapis-gen/commit/febf173172483fcebd5668dd32f3d7352a4420ce Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZmViZjE3MzE3MjQ4M2ZjZWJkNTY2OGRkMzJmM2Q3MzUyYTQ0MjBjZSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
diff --git a/protos/google/dataflow/v1beta3/environment.proto b/protos/google/dataflow/v1beta3/environment.proto
@@ -415,6 +415,10 @@ message SdkHarnessContainerImage {
   // Environment ID for the Beam runner API proto Environment that corresponds
   // to the current SDK Harness.
   string environment_id = 3;
+
+  // The set of capabilities enumerated in the above Environment proto. See also
+  // https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto
+  repeated string capabilities = 4;
 }
 
 // Describes one particular pool of Cloud Dataflow workers to be
diff --git a/protos/protos.d.ts b/protos/protos.d.ts
diff --git a/protos/protos.js b/protos/protos.js
diff --git a/protos/protos.json b/protos/protos.json
diff --git a/test/gapic_flex_templates_service_v1beta3.ts b/test/gapic_flex_templates_service_v1beta3.ts
@@ -280,7 +280,6 @@ describe('v1beta3.FlexTemplatesServiceClient', () => {
         new protos.google.dataflow.v1beta3.LaunchFlexTemplateRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.launchFlexTemplate(request), expectedError);
diff --git a/test/gapic_jobs_v1_beta3_v1beta3.ts b/test/gapic_jobs_v1_beta3_v1beta3.ts
@@ -325,7 +325,6 @@ describe('v1beta3.JobsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.CreateJobRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.createJob(request), expectedError);
@@ -449,7 +448,6 @@ describe('v1beta3.JobsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.GetJobRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getJob(request), expectedError);
@@ -573,7 +571,6 @@ describe('v1beta3.JobsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.UpdateJobRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.updateJob(request), expectedError);
@@ -801,7 +798,6 @@ describe('v1beta3.JobsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.SnapshotJobRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.snapshotJob(request), expectedError);
diff --git a/test/gapic_metrics_v1_beta3_v1beta3.ts b/test/gapic_metrics_v1_beta3_v1beta3.ts
@@ -330,7 +330,6 @@ describe('v1beta3.MetricsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.GetJobMetricsRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getJobMetrics(request), expectedError);
diff --git a/test/gapic_snapshots_v1_beta3_v1beta3.ts b/test/gapic_snapshots_v1_beta3_v1beta3.ts
@@ -267,7 +267,6 @@ describe('v1beta3.SnapshotsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.GetSnapshotRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getSnapshot(request), expectedError);
@@ -394,7 +393,6 @@ describe('v1beta3.SnapshotsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.DeleteSnapshotRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.deleteSnapshot(request), expectedError);
@@ -521,7 +519,6 @@ describe('v1beta3.SnapshotsV1Beta3Client', () => {
         new protos.google.dataflow.v1beta3.ListSnapshotsRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.listSnapshots(request), expectedError);
diff --git a/test/gapic_templates_service_v1beta3.ts b/test/gapic_templates_service_v1beta3.ts
@@ -271,7 +271,6 @@ describe('v1beta3.TemplatesServiceClient', () => {
         new protos.google.dataflow.v1beta3.CreateJobFromTemplateRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(
@@ -401,7 +400,6 @@ describe('v1beta3.TemplatesServiceClient', () => {
         new protos.google.dataflow.v1beta3.LaunchTemplateRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.launchTemplate(request), expectedError);
@@ -528,7 +526,6 @@ describe('v1beta3.TemplatesServiceClient', () => {
         new protos.google.dataflow.v1beta3.GetTemplateRequest()
       );
       request.projectId = '';
-      const expectedHeaderRequestParams = 'project_id=';
       const expectedError = new Error('The client has already been closed.');
       client.close();
       await assert.rejects(client.getTemplate(request), expectedError);
