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

require 'google/protobuf'

require 'google/api/field_behavior_pb'
require 'google/api/resource_pb'
require 'google/cloud/dataplex/v1/resources_pb'
require 'google/protobuf/duration_pb'
require 'google/protobuf/timestamp_pb'

Google::Protobuf::DescriptorPool.generated_pool.build do
  add_file("google/cloud/dataplex/v1/tasks.proto", :syntax => :proto3) do
    add_message "google.cloud.dataplex.v1.Task" do
      optional :name, :string, 1
      optional :uid, :string, 2
      optional :create_time, :message, 3, "google.protobuf.Timestamp"
      optional :update_time, :message, 4, "google.protobuf.Timestamp"
      optional :description, :string, 5
      optional :display_name, :string, 6
      optional :state, :enum, 7, "google.cloud.dataplex.v1.State"
      map :labels, :string, :string, 8
      optional :trigger_spec, :message, 100, "google.cloud.dataplex.v1.Task.TriggerSpec"
      optional :execution_spec, :message, 101, "google.cloud.dataplex.v1.Task.ExecutionSpec"
      optional :execution_status, :message, 201, "google.cloud.dataplex.v1.Task.ExecutionStatus"
      oneof :config do
        optional :spark, :message, 300, "google.cloud.dataplex.v1.Task.SparkTaskConfig"
        optional :notebook, :message, 302, "google.cloud.dataplex.v1.Task.NotebookTaskConfig"
      end
    end
    add_message "google.cloud.dataplex.v1.Task.InfrastructureSpec" do
      oneof :resources do
        optional :batch, :message, 52, "google.cloud.dataplex.v1.Task.InfrastructureSpec.BatchComputeResources"
      end
      oneof :runtime do
        optional :container_image, :message, 101, "google.cloud.dataplex.v1.Task.InfrastructureSpec.ContainerImageRuntime"
      end
      oneof :network do
        optional :vpc_network, :message, 150, "google.cloud.dataplex.v1.Task.InfrastructureSpec.VpcNetwork"
      end
    end
    add_message "google.cloud.dataplex.v1.Task.InfrastructureSpec.BatchComputeResources" do
      optional :executors_count, :int32, 1
      optional :max_executors_count, :int32, 2
    end
    add_message "google.cloud.dataplex.v1.Task.InfrastructureSpec.ContainerImageRuntime" do
      optional :image, :string, 1
      repeated :java_jars, :string, 2
      repeated :python_packages, :string, 3
      map :properties, :string, :string, 4
    end
    add_message "google.cloud.dataplex.v1.Task.InfrastructureSpec.VpcNetwork" do
      repeated :network_tags, :string, 3
      oneof :network_name do
        optional :network, :string, 1
        optional :sub_network, :string, 2
      end
    end
    add_message "google.cloud.dataplex.v1.Task.TriggerSpec" do
      optional :type, :enum, 5, "google.cloud.dataplex.v1.Task.TriggerSpec.Type"
      optional :start_time, :message, 6, "google.protobuf.Timestamp"
      optional :disabled, :bool, 4
      optional :max_retries, :int32, 7
      oneof :trigger do
        optional :schedule, :string, 100
      end
    end
    add_enum "google.cloud.dataplex.v1.Task.TriggerSpec.Type" do
      value :TYPE_UNSPECIFIED, 0
      value :ON_DEMAND, 1
      value :RECURRING, 2
    end
    add_message "google.cloud.dataplex.v1.Task.ExecutionSpec" do
      map :args, :string, :string, 4
      optional :service_account, :string, 5
      optional :project, :string, 7
      optional :max_job_execution_lifetime, :message, 8, "google.protobuf.Duration"
      optional :kms_key, :string, 9
    end
    add_message "google.cloud.dataplex.v1.Task.SparkTaskConfig" do
      repeated :file_uris, :string, 3
      repeated :archive_uris, :string, 4
      optional :infrastructure_spec, :message, 6, "google.cloud.dataplex.v1.Task.InfrastructureSpec"
      oneof :driver do
        optional :main_jar_file_uri, :string, 100
        optional :main_class, :string, 101
        optional :python_script_file, :string, 102
        optional :sql_script_file, :string, 104
        optional :sql_script, :string, 105
      end
    end
    add_message "google.cloud.dataplex.v1.Task.NotebookTaskConfig" do
      optional :notebook, :string, 4
      optional :infrastructure_spec, :message, 3, "google.cloud.dataplex.v1.Task.InfrastructureSpec"
      repeated :file_uris, :string, 5
      repeated :archive_uris, :string, 6
    end
    add_message "google.cloud.dataplex.v1.Task.ExecutionStatus" do
      optional :update_time, :message, 3, "google.protobuf.Timestamp"
      optional :latest_job, :message, 9, "google.cloud.dataplex.v1.Job"
    end
    add_message "google.cloud.dataplex.v1.Job" do
      optional :name, :string, 1
      optional :uid, :string, 2
      optional :start_time, :message, 3, "google.protobuf.Timestamp"
      optional :end_time, :message, 4, "google.protobuf.Timestamp"
      optional :state, :enum, 5, "google.cloud.dataplex.v1.Job.State"
      optional :retry_count, :uint32, 6
      optional :service, :enum, 7, "google.cloud.dataplex.v1.Job.Service"
      optional :service_job, :string, 8
      optional :message, :string, 9
    end
    add_enum "google.cloud.dataplex.v1.Job.Service" do
      value :SERVICE_UNSPECIFIED, 0
      value :DATAPROC, 1
    end
    add_enum "google.cloud.dataplex.v1.Job.State" do
      value :STATE_UNSPECIFIED, 0
      value :RUNNING, 1
      value :CANCELLING, 2
      value :CANCELLED, 3
      value :SUCCEEDED, 4
      value :FAILED, 5
      value :ABORTED, 6
    end
  end
end

module Google
  module Cloud
    module Dataplex
      module V1
        Task = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task").msgclass
        Task::InfrastructureSpec = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.InfrastructureSpec").msgclass
        Task::InfrastructureSpec::BatchComputeResources = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.InfrastructureSpec.BatchComputeResources").msgclass
        Task::InfrastructureSpec::ContainerImageRuntime = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.InfrastructureSpec.ContainerImageRuntime").msgclass
        Task::InfrastructureSpec::VpcNetwork = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.InfrastructureSpec.VpcNetwork").msgclass
        Task::TriggerSpec = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.TriggerSpec").msgclass
        Task::TriggerSpec::Type = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.TriggerSpec.Type").enummodule
        Task::ExecutionSpec = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.ExecutionSpec").msgclass
        Task::SparkTaskConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.SparkTaskConfig").msgclass
        Task::NotebookTaskConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.NotebookTaskConfig").msgclass
        Task::ExecutionStatus = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Task.ExecutionStatus").msgclass
        Job = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Job").msgclass
        Job::Service = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Job.Service").enummodule
        Job::State = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.dataplex.v1.Job.State").enummodule
      end
    end
  end
end