# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/cloud/dataproc/v1/workflow_templates.proto


require 'google/protobuf'

require 'google/api/annotations_pb'
require 'google/api/client_pb'
require 'google/api/field_behavior_pb'
require 'google/api/resource_pb'
require 'google/cloud/dataproc/v1/clusters_pb'
require 'google/cloud/dataproc/v1/jobs_pb'
require 'google/longrunning/operations_pb'
require 'google/protobuf/empty_pb'
require 'google/protobuf/timestamp_pb'
Google::Protobuf::DescriptorPool.generated_pool.build do
  add_message "google.cloud.dataproc.v1.WorkflowTemplate" do
    optional :id, :string, 2
    optional :name, :string, 1
    optional :version, :int32, 3
    optional :create_time, :message, 4, "google.protobuf.Timestamp"
    optional :update_time, :message, 5, "google.protobuf.Timestamp"
    map :labels, :string, :string, 6
    optional :placement, :message, 7, "google.cloud.dataproc.v1.WorkflowTemplatePlacement"
    repeated :jobs, :message, 8, "google.cloud.dataproc.v1.OrderedJob"
    repeated :parameters, :message, 9, "google.cloud.dataproc.v1.TemplateParameter"
  end
  add_message "google.cloud.dataproc.v1.WorkflowTemplatePlacement" do
    oneof :placement do
      optional :managed_cluster, :message, 1, "google.cloud.dataproc.v1.ManagedCluster"
      optional :cluster_selector, :message, 2, "google.cloud.dataproc.v1.ClusterSelector"
    end
  end
  add_message "google.cloud.dataproc.v1.ManagedCluster" do
    optional :cluster_name, :string, 2
    optional :config, :message, 3, "google.cloud.dataproc.v1.ClusterConfig"
    map :labels, :string, :string, 4
  end
  add_message "google.cloud.dataproc.v1.ClusterSelector" do
    optional :zone, :string, 1
    map :cluster_labels, :string, :string, 2
  end
  add_message "google.cloud.dataproc.v1.OrderedJob" do
    optional :step_id, :string, 1
    map :labels, :string, :string, 8
    optional :scheduling, :message, 9, "google.cloud.dataproc.v1.JobScheduling"
    repeated :prerequisite_step_ids, :string, 10
    oneof :job_type do
      optional :hadoop_job, :message, 2, "google.cloud.dataproc.v1.HadoopJob"
      optional :spark_job, :message, 3, "google.cloud.dataproc.v1.SparkJob"
      optional :pyspark_job, :message, 4, "google.cloud.dataproc.v1.PySparkJob"
      optional :hive_job, :message, 5, "google.cloud.dataproc.v1.HiveJob"
      optional :pig_job, :message, 6, "google.cloud.dataproc.v1.PigJob"
      optional :spark_sql_job, :message, 7, "google.cloud.dataproc.v1.SparkSqlJob"
    end
  end
  add_message "google.cloud.dataproc.v1.TemplateParameter" do
    optional :name, :string, 1
    repeated :fields, :string, 2
    optional :description, :string, 3
    optional :validation, :message, 4, "google.cloud.dataproc.v1.ParameterValidation"
  end
  add_message "google.cloud.dataproc.v1.ParameterValidation" do
    oneof :validation_type do
      optional :regex, :message, 1, "google.cloud.dataproc.v1.RegexValidation"
      optional :values, :message, 2, "google.cloud.dataproc.v1.ValueValidation"
    end
  end
  add_message "google.cloud.dataproc.v1.RegexValidation" do
    repeated :regexes, :string, 1
  end
  add_message "google.cloud.dataproc.v1.ValueValidation" do
    repeated :values, :string, 1
  end
  add_message "google.cloud.dataproc.v1.WorkflowMetadata" do
    optional :template, :string, 1
    optional :version, :int32, 2
    optional :create_cluster, :message, 3, "google.cloud.dataproc.v1.ClusterOperation"
    optional :graph, :message, 4, "google.cloud.dataproc.v1.WorkflowGraph"
    optional :delete_cluster, :message, 5, "google.cloud.dataproc.v1.ClusterOperation"
    optional :state, :enum, 6, "google.cloud.dataproc.v1.WorkflowMetadata.State"
    optional :cluster_name, :string, 7
    map :parameters, :string, :string, 8
    optional :start_time, :message, 9, "google.protobuf.Timestamp"
    optional :end_time, :message, 10, "google.protobuf.Timestamp"
    optional :cluster_uuid, :string, 11
  end
  add_enum "google.cloud.dataproc.v1.WorkflowMetadata.State" do
    value :UNKNOWN, 0
    value :PENDING, 1
    value :RUNNING, 2
    value :DONE, 3
  end
  add_message "google.cloud.dataproc.v1.ClusterOperation" do
    optional :operation_id, :string, 1
    optional :error, :string, 2
    optional :done, :bool, 3
  end
  add_message "google.cloud.dataproc.v1.WorkflowGraph" do
    repeated :nodes, :message, 1, "google.cloud.dataproc.v1.WorkflowNode"
  end
  add_message "google.cloud.dataproc.v1.WorkflowNode" do
    optional :step_id, :string, 1
    repeated :prerequisite_step_ids, :string, 2
    optional :job_id, :string, 3
    optional :state, :enum, 5, "google.cloud.dataproc.v1.WorkflowNode.NodeState"
    optional :error, :string, 6
  end
  add_enum "google.cloud.dataproc.v1.WorkflowNode.NodeState" do
    value :NODE_STATE_UNSPECIFIED, 0
    value :BLOCKED, 1
    value :RUNNABLE, 2
    value :RUNNING, 3
    value :COMPLETED, 4
    value :FAILED, 5
  end
  add_message "google.cloud.dataproc.v1.CreateWorkflowTemplateRequest" do
    optional :parent, :string, 1
    optional :template, :message, 2, "google.cloud.dataproc.v1.WorkflowTemplate"
  end
  add_message "google.cloud.dataproc.v1.GetWorkflowTemplateRequest" do
    optional :name, :string, 1
    optional :version, :int32, 2
  end
  add_message "google.cloud.dataproc.v1.InstantiateWorkflowTemplateRequest" do
    optional :name, :string, 1
    optional :version, :int32, 2
    optional :request_id, :string, 5
    map :parameters, :string, :string, 6
  end
  add_message "google.cloud.dataproc.v1.InstantiateInlineWorkflowTemplateRequest" do
    optional :parent, :string, 1
    optional :template, :message, 2, "google.cloud.dataproc.v1.WorkflowTemplate"
    optional :request_id, :string, 3
  end
  add_message "google.cloud.dataproc.v1.UpdateWorkflowTemplateRequest" do
    optional :template, :message, 1, "google.cloud.dataproc.v1.WorkflowTemplate"
  end
  add_message "google.cloud.dataproc.v1.ListWorkflowTemplatesRequest" do
    optional :parent, :string, 1
    optional :page_size, :int32, 2
    optional :page_token, :string, 3
  end
  add_message "google.cloud.dataproc.v1.ListWorkflowTemplatesResponse" do
    repeated :templates, :message, 1, "google.cloud.dataproc.v1.WorkflowTemplate"
    optional :next_page_token, :string, 2
  end
  add_message "google.cloud.dataproc.v1.DeleteWorkflowTemplateRequest" do
    optional :name, :string, 1
    optional :version, :int32, 2
  end
end

module Google
  module Cloud
    module Dataproc
      module V1
        WorkflowTemplate = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowTemplate").msgclass
        WorkflowTemplatePlacement = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowTemplatePlacement").msgclass
        ManagedCluster = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ManagedCluster").msgclass
        ClusterSelector = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ClusterSelector").msgclass
        OrderedJob = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.OrderedJob").msgclass
        TemplateParameter = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.TemplateParameter").msgclass
        ParameterValidation = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ParameterValidation").msgclass
        RegexValidation = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.RegexValidation").msgclass
        ValueValidation = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ValueValidation").msgclass
        WorkflowMetadata = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowMetadata").msgclass
        WorkflowMetadata::State = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowMetadata.State").enummodule
        ClusterOperation = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ClusterOperation").msgclass
        WorkflowGraph = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowGraph").msgclass
        WorkflowNode = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowNode").msgclass
        WorkflowNode::NodeState = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.WorkflowNode.NodeState").enummodule
        CreateWorkflowTemplateRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.CreateWorkflowTemplateRequest").msgclass
        GetWorkflowTemplateRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.GetWorkflowTemplateRequest").msgclass
        InstantiateWorkflowTemplateRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.InstantiateWorkflowTemplateRequest").msgclass
        InstantiateInlineWorkflowTemplateRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.InstantiateInlineWorkflowTemplateRequest").msgclass
        UpdateWorkflowTemplateRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.UpdateWorkflowTemplateRequest").msgclass
        ListWorkflowTemplatesRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ListWorkflowTemplatesRequest").msgclass
        ListWorkflowTemplatesResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.ListWorkflowTemplatesResponse").msgclass
        DeleteWorkflowTemplateRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataproc.v1.DeleteWorkflowTemplateRequest").msgclass
      end
    end
  end
end