From 5378173a889f9c7d83e36e52d38a6267190de692 Mon Sep 17 00:00:00 2001
From: Google APIs <noreply@google.com>
Date: Fri, 3 Apr 2020 05:15:57 -0700
Subject: [PATCH] Add v1beta2 SubmitJobAsOperation RPC to Dataproc.

PiperOrigin-RevId: 304594381
---
 .../v1beta2/dataproc_grpc_service_config.json |  4 +++
 .../dataproc/v1beta2/dataproc_v1beta2.yaml    |  1 +
 google/cloud/dataproc/v1beta2/jobs.proto      | 28 +++++++++++++++++++
 3 files changed, 33 insertions(+)

diff --git a/google/cloud/dataproc/v1beta2/dataproc_grpc_service_config.json b/google/cloud/dataproc/v1beta2/dataproc_grpc_service_config.json
index 599c7e46..050c44ca 100755
--- a/google/cloud/dataproc/v1beta2/dataproc_grpc_service_config.json
+++ b/google/cloud/dataproc/v1beta2/dataproc_grpc_service_config.json
@@ -97,6 +97,10 @@
           "service": "google.cloud.dataproc.v1beta2.JobController",
           "method": "SubmitJob"
         },
+        {
+          "service": "google.cloud.dataproc.v1beta2.JobController",
+          "method": "SubmitJobAsOperation"
+        },
         {
           "service": "google.cloud.dataproc.v1beta2.JobController",
           "method": "UpdateJob"
diff --git a/google/cloud/dataproc/v1beta2/dataproc_v1beta2.yaml b/google/cloud/dataproc/v1beta2/dataproc_v1beta2.yaml
index 15ed0c2c..ebdfc6b4 100644
--- a/google/cloud/dataproc/v1beta2/dataproc_v1beta2.yaml
+++ b/google/cloud/dataproc/v1beta2/dataproc_v1beta2.yaml
@@ -12,6 +12,7 @@ apis:
 types:
 - name: google.cloud.dataproc.v1beta2.ClusterOperationMetadata
 - name: google.cloud.dataproc.v1beta2.DiagnoseClusterResults
+- name: google.cloud.dataproc.v1beta2.JobMetadata
 - name: google.cloud.dataproc.v1beta2.WorkflowMetadata
 
 documentation:
diff --git a/google/cloud/dataproc/v1beta2/jobs.proto b/google/cloud/dataproc/v1beta2/jobs.proto
index 3208822f..735251df 100644
--- a/google/cloud/dataproc/v1beta2/jobs.proto
+++ b/google/cloud/dataproc/v1beta2/jobs.proto
@@ -43,6 +43,19 @@ service JobController {
     option (google.api.method_signature) = "project_id, region, job";
   }
 
+  // Submits job to a cluster.
+  rpc SubmitJobAsOperation(SubmitJobRequest) returns (google.longrunning.Operation) {
+    option (google.api.http) = {
+      post: "/v1beta2/projects/{project_id}/regions/{region}/jobs:submitAsOperation"
+      body: "*"
+    };
+    option (google.api.method_signature) = "project_id, region, job";
+    option (google.longrunning.operation_info) = {
+      response_type: "Job"
+      metadata_type: "JobMetadata"
+    };
+  }
+
   // Gets the resource representation for a job in a project.
   rpc GetJob(GetJobRequest) returns (Job) {
     option (google.api.http) = {
@@ -664,6 +677,21 @@ message JobScheduling {
   int32 max_failures_per_hour = 1 [(google.api.field_behavior) = OPTIONAL];
 }
 
+// Job Operation metadata.
+message JobMetadata {
+  // Output only. The job id.
+  string job_id = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
+
+  // Output only. Most recent job status.
+  JobStatus status = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+
+  // Output only. Operation type.
+  string operation_type = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+
+  // Output only. Job submission time.
+  google.protobuf.Timestamp start_time = 4 [(google.api.field_behavior) = OUTPUT_ONLY];
+}
+
 // A request to submit a job.
 message SubmitJobRequest {
   // Required. The ID of the Google Cloud Platform project that the job