// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.6
// 	protoc        v3.21.12
// source: yandex/cloud/datasphere/v2/jobs/jobs.proto

package datasphere

import (
	_ "github.com/yandex-cloud/go-genproto/yandex/cloud"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	durationpb "google.golang.org/protobuf/types/known/durationpb"
	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

type FileCompressionType int32

const (
	FileCompressionType_FILE_COMPRESSION_TYPE_UNSPECIFIED FileCompressionType = 0
	FileCompressionType_NONE                              FileCompressionType = 1
	FileCompressionType_ZIP                               FileCompressionType = 2
)

// Enum value maps for FileCompressionType.
var (
	FileCompressionType_name = map[int32]string{
		0: "FILE_COMPRESSION_TYPE_UNSPECIFIED",
		1: "NONE",
		2: "ZIP",
	}
	FileCompressionType_value = map[string]int32{
		"FILE_COMPRESSION_TYPE_UNSPECIFIED": 0,
		"NONE":                              1,
		"ZIP":                               2,
	}
)

func (x FileCompressionType) Enum() *FileCompressionType {
	p := new(FileCompressionType)
	*p = x
	return p
}

func (x FileCompressionType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (FileCompressionType) Descriptor() protoreflect.EnumDescriptor {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[0].Descriptor()
}

func (FileCompressionType) Type() protoreflect.EnumType {
	return &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[0]
}

func (x FileCompressionType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use FileCompressionType.Descriptor instead.
func (FileCompressionType) EnumDescriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{0}
}

type JobStatus int32

const (
	JobStatus_JOB_STATUS_UNSPECIFIED JobStatus = 0
	JobStatus_CREATING               JobStatus = 1
	JobStatus_EXECUTING              JobStatus = 2
	JobStatus_UPLOADING_OUTPUT       JobStatus = 3
	JobStatus_SUCCESS                JobStatus = 4
	JobStatus_ERROR                  JobStatus = 5
	JobStatus_CANCELLED              JobStatus = 6
	JobStatus_CANCELLING             JobStatus = 7
	JobStatus_PREPARING              JobStatus = 8
)

// Enum value maps for JobStatus.
var (
	JobStatus_name = map[int32]string{
		0: "JOB_STATUS_UNSPECIFIED",
		1: "CREATING",
		2: "EXECUTING",
		3: "UPLOADING_OUTPUT",
		4: "SUCCESS",
		5: "ERROR",
		6: "CANCELLED",
		7: "CANCELLING",
		8: "PREPARING",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_UNSPECIFIED": 0,
		"CREATING":               1,
		"EXECUTING":              2,
		"UPLOADING_OUTPUT":       3,
		"SUCCESS":                4,
		"ERROR":                  5,
		"CANCELLED":              6,
		"CANCELLING":             7,
		"PREPARING":              8,
	}
)

func (x JobStatus) Enum() *JobStatus {
	p := new(JobStatus)
	*p = x
	return p
}

func (x JobStatus) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (JobStatus) Descriptor() protoreflect.EnumDescriptor {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[1].Descriptor()
}

func (JobStatus) Type() protoreflect.EnumType {
	return &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[1]
}

func (x JobStatus) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use JobStatus.Descriptor instead.
func (JobStatus) EnumDescriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{1}
}

type ExtendedWorkingStorage_StorageType int32

const (
	ExtendedWorkingStorage_STORAGE_TYPE_UNSPECIFIED ExtendedWorkingStorage_StorageType = 0
	ExtendedWorkingStorage_SSD                      ExtendedWorkingStorage_StorageType = 1
)

// Enum value maps for ExtendedWorkingStorage_StorageType.
var (
	ExtendedWorkingStorage_StorageType_name = map[int32]string{
		0: "STORAGE_TYPE_UNSPECIFIED",
		1: "SSD",
	}
	ExtendedWorkingStorage_StorageType_value = map[string]int32{
		"STORAGE_TYPE_UNSPECIFIED": 0,
		"SSD":                      1,
	}
)

func (x ExtendedWorkingStorage_StorageType) Enum() *ExtendedWorkingStorage_StorageType {
	p := new(ExtendedWorkingStorage_StorageType)
	*p = x
	return p
}

func (x ExtendedWorkingStorage_StorageType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (ExtendedWorkingStorage_StorageType) Descriptor() protoreflect.EnumDescriptor {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[2].Descriptor()
}

func (ExtendedWorkingStorage_StorageType) Type() protoreflect.EnumType {
	return &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[2]
}

func (x ExtendedWorkingStorage_StorageType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use ExtendedWorkingStorage_StorageType.Descriptor instead.
func (ExtendedWorkingStorage_StorageType) EnumDescriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{2, 0}
}

type FileUploadError_ErrorType int32

const (
	FileUploadError_ERROR_TYPE_UNSPECIFIED FileUploadError_ErrorType = 0
	FileUploadError_UPLOAD_FAILED          FileUploadError_ErrorType = 1
	FileUploadError_NOT_FOUND              FileUploadError_ErrorType = 2
)

// Enum value maps for FileUploadError_ErrorType.
var (
	FileUploadError_ErrorType_name = map[int32]string{
		0: "ERROR_TYPE_UNSPECIFIED",
		1: "UPLOAD_FAILED",
		2: "NOT_FOUND",
	}
	FileUploadError_ErrorType_value = map[string]int32{
		"ERROR_TYPE_UNSPECIFIED": 0,
		"UPLOAD_FAILED":          1,
		"NOT_FOUND":              2,
	}
)

func (x FileUploadError_ErrorType) Enum() *FileUploadError_ErrorType {
	p := new(FileUploadError_ErrorType)
	*p = x
	return p
}

func (x FileUploadError_ErrorType) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (FileUploadError_ErrorType) Descriptor() protoreflect.EnumDescriptor {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[3].Descriptor()
}

func (FileUploadError_ErrorType) Type() protoreflect.EnumType {
	return &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes[3]
}

func (x FileUploadError_ErrorType) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use FileUploadError_ErrorType.Descriptor instead.
func (FileUploadError_ErrorType) EnumDescriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{7, 0}
}

// Job parameters.
type JobParameters struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// List of input files.
	InputFiles []*File `protobuf:"bytes,1,rep,name=input_files,json=inputFiles,proto3" json:"input_files,omitempty"`
	// List of output files descriptions.
	OutputFiles []*FileDesc `protobuf:"bytes,2,rep,name=output_files,json=outputFiles,proto3" json:"output_files,omitempty"`
	// List of DataSphere S3 mount ids.
	S3MountIds []string `protobuf:"bytes,3,rep,name=s3_mount_ids,json=s3MountIds,proto3" json:"s3_mount_ids,omitempty"`
	// List of DataSphere dataset ids.
	DatasetIds []string `protobuf:"bytes,4,rep,name=dataset_ids,json=datasetIds,proto3" json:"dataset_ids,omitempty"`
	// Job run command.
	Cmd string `protobuf:"bytes,5,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// Job environment description.
	Env *Environment `protobuf:"bytes,6,opt,name=env,proto3" json:"env,omitempty"`
	// Should project disk be attached to VM.
	AttachProjectDisk bool `protobuf:"varint,7,opt,name=attach_project_disk,json=attachProjectDisk,proto3" json:"attach_project_disk,omitempty"`
	// VM specification.
	CloudInstanceTypes []*CloudInstanceType `protobuf:"bytes,8,rep,name=cloud_instance_types,json=cloudInstanceTypes,proto3" json:"cloud_instance_types,omitempty"`
	// Extended working storage configuration.
	ExtendedWorkingStorage *ExtendedWorkingStorage `protobuf:"bytes,9,opt,name=extended_working_storage,json=extendedWorkingStorage,proto3" json:"extended_working_storage,omitempty"`
	// List of literal arguments.
	Arguments []*Argument `protobuf:"bytes,10,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// List of DataSets descriptions to create.
	OutputDatasets []*OutputDatasetDesc `protobuf:"bytes,11,rep,name=output_datasets,json=outputDatasets,proto3" json:"output_datasets,omitempty"`
	// Graceful shutdown settings.
	GracefulShutdownParameters *GracefulShutdownParameters `protobuf:"bytes,12,opt,name=graceful_shutdown_parameters,json=gracefulShutdownParameters,proto3" json:"graceful_shutdown_parameters,omitempty"`
	// Spark connector settings.
	SparkParameters *SparkParameters `protobuf:"bytes,13,opt,name=spark_parameters,json=sparkParameters,proto3" json:"spark_parameters,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *JobParameters) Reset() {
	*x = JobParameters{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JobParameters) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JobParameters) ProtoMessage() {}

func (x *JobParameters) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use JobParameters.ProtoReflect.Descriptor instead.
func (*JobParameters) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{0}
}

func (x *JobParameters) GetInputFiles() []*File {
	if x != nil {
		return x.InputFiles
	}
	return nil
}

func (x *JobParameters) GetOutputFiles() []*FileDesc {
	if x != nil {
		return x.OutputFiles
	}
	return nil
}

func (x *JobParameters) GetS3MountIds() []string {
	if x != nil {
		return x.S3MountIds
	}
	return nil
}

func (x *JobParameters) GetDatasetIds() []string {
	if x != nil {
		return x.DatasetIds
	}
	return nil
}

func (x *JobParameters) GetCmd() string {
	if x != nil {
		return x.Cmd
	}
	return ""
}

func (x *JobParameters) GetEnv() *Environment {
	if x != nil {
		return x.Env
	}
	return nil
}

func (x *JobParameters) GetAttachProjectDisk() bool {
	if x != nil {
		return x.AttachProjectDisk
	}
	return false
}

func (x *JobParameters) GetCloudInstanceTypes() []*CloudInstanceType {
	if x != nil {
		return x.CloudInstanceTypes
	}
	return nil
}

func (x *JobParameters) GetExtendedWorkingStorage() *ExtendedWorkingStorage {
	if x != nil {
		return x.ExtendedWorkingStorage
	}
	return nil
}

func (x *JobParameters) GetArguments() []*Argument {
	if x != nil {
		return x.Arguments
	}
	return nil
}

func (x *JobParameters) GetOutputDatasets() []*OutputDatasetDesc {
	if x != nil {
		return x.OutputDatasets
	}
	return nil
}

func (x *JobParameters) GetGracefulShutdownParameters() *GracefulShutdownParameters {
	if x != nil {
		return x.GracefulShutdownParameters
	}
	return nil
}

func (x *JobParameters) GetSparkParameters() *SparkParameters {
	if x != nil {
		return x.SparkParameters
	}
	return nil
}

type CloudInstanceType struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Name of DataSphere VM configuration.
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CloudInstanceType) Reset() {
	*x = CloudInstanceType{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CloudInstanceType) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CloudInstanceType) ProtoMessage() {}

func (x *CloudInstanceType) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CloudInstanceType.ProtoReflect.Descriptor instead.
func (*CloudInstanceType) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{1}
}

func (x *CloudInstanceType) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

// Extended working storage configuration.
type ExtendedWorkingStorage struct {
	state         protoimpl.MessageState             `protogen:"open.v1"`
	Type          ExtendedWorkingStorage_StorageType `protobuf:"varint,1,opt,name=type,proto3,enum=yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage_StorageType" json:"type,omitempty"`
	SizeGb        int64                              `protobuf:"varint,2,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ExtendedWorkingStorage) Reset() {
	*x = ExtendedWorkingStorage{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ExtendedWorkingStorage) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ExtendedWorkingStorage) ProtoMessage() {}

func (x *ExtendedWorkingStorage) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ExtendedWorkingStorage.ProtoReflect.Descriptor instead.
func (*ExtendedWorkingStorage) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{2}
}

func (x *ExtendedWorkingStorage) GetType() ExtendedWorkingStorage_StorageType {
	if x != nil {
		return x.Type
	}
	return ExtendedWorkingStorage_STORAGE_TYPE_UNSPECIFIED
}

func (x *ExtendedWorkingStorage) GetSizeGb() int64 {
	if x != nil {
		return x.SizeGb
	}
	return 0
}

type Argument struct {
	state         protoimpl.MessageState `protogen:"open.v1"`
	Name          string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value         string                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Argument) Reset() {
	*x = Argument{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Argument) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Argument) ProtoMessage() {}

func (x *Argument) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Argument.ProtoReflect.Descriptor instead.
func (*Argument) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{3}
}

func (x *Argument) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *Argument) GetValue() string {
	if x != nil {
		return x.Value
	}
	return ""
}

type File struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	Desc  *FileDesc              `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
	// SHA256 of the file.
	Sha256 string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// File size in bytes.
	SizeBytes int64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// File compression info
	CompressionType FileCompressionType `protobuf:"varint,4,opt,name=compression_type,json=compressionType,proto3,enum=yandex.cloud.datasphere.v2.jobs.FileCompressionType" json:"compression_type,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *File) Reset() {
	*x = File{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *File) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*File) ProtoMessage() {}

func (x *File) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use File.ProtoReflect.Descriptor instead.
func (*File) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{4}
}

func (x *File) GetDesc() *FileDesc {
	if x != nil {
		return x.Desc
	}
	return nil
}

func (x *File) GetSha256() string {
	if x != nil {
		return x.Sha256
	}
	return ""
}

func (x *File) GetSizeBytes() int64 {
	if x != nil {
		return x.SizeBytes
	}
	return 0
}

func (x *File) GetCompressionType() FileCompressionType {
	if x != nil {
		return x.CompressionType
	}
	return FileCompressionType_FILE_COMPRESSION_TYPE_UNSPECIFIED
}

type StorageFile struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	File  *File                  `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	// File URL.
	Url           string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StorageFile) Reset() {
	*x = StorageFile{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StorageFile) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StorageFile) ProtoMessage() {}

func (x *StorageFile) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StorageFile.ProtoReflect.Descriptor instead.
func (*StorageFile) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{5}
}

func (x *StorageFile) GetFile() *File {
	if x != nil {
		return x.File
	}
	return nil
}

func (x *StorageFile) GetUrl() string {
	if x != nil {
		return x.Url
	}
	return ""
}

type FileDesc struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Path of the file on filesystem.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Variable to use in cmd substitution.
	Var           string `protobuf:"bytes,2,opt,name=var,proto3" json:"var,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *FileDesc) Reset() {
	*x = FileDesc{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *FileDesc) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*FileDesc) ProtoMessage() {}

func (x *FileDesc) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use FileDesc.ProtoReflect.Descriptor instead.
func (*FileDesc) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{6}
}

func (x *FileDesc) GetPath() string {
	if x != nil {
		return x.Path
	}
	return ""
}

func (x *FileDesc) GetVar() string {
	if x != nil {
		return x.Var
	}
	return ""
}

type FileUploadError struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to FileType:
	//
	//	*FileUploadError_OutputFileDesc
	//	*FileUploadError_LogFileName
	FileType      isFileUploadError_FileType `protobuf_oneof:"file_type"`
	Description   string                     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Type          FileUploadError_ErrorType  `protobuf:"varint,4,opt,name=type,proto3,enum=yandex.cloud.datasphere.v2.jobs.FileUploadError_ErrorType" json:"type,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *FileUploadError) Reset() {
	*x = FileUploadError{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *FileUploadError) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*FileUploadError) ProtoMessage() {}

func (x *FileUploadError) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use FileUploadError.ProtoReflect.Descriptor instead.
func (*FileUploadError) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{7}
}

func (x *FileUploadError) GetFileType() isFileUploadError_FileType {
	if x != nil {
		return x.FileType
	}
	return nil
}

func (x *FileUploadError) GetOutputFileDesc() *FileDesc {
	if x != nil {
		if x, ok := x.FileType.(*FileUploadError_OutputFileDesc); ok {
			return x.OutputFileDesc
		}
	}
	return nil
}

func (x *FileUploadError) GetLogFileName() string {
	if x != nil {
		if x, ok := x.FileType.(*FileUploadError_LogFileName); ok {
			return x.LogFileName
		}
	}
	return ""
}

func (x *FileUploadError) GetDescription() string {
	if x != nil {
		return x.Description
	}
	return ""
}

func (x *FileUploadError) GetType() FileUploadError_ErrorType {
	if x != nil {
		return x.Type
	}
	return FileUploadError_ERROR_TYPE_UNSPECIFIED
}

type isFileUploadError_FileType interface {
	isFileUploadError_FileType()
}

type FileUploadError_OutputFileDesc struct {
	OutputFileDesc *FileDesc `protobuf:"bytes,1,opt,name=output_file_desc,json=outputFileDesc,proto3,oneof"`
}

type FileUploadError_LogFileName struct {
	LogFileName string `protobuf:"bytes,2,opt,name=log_file_name,json=logFileName,proto3,oneof"`
}

func (*FileUploadError_OutputFileDesc) isFileUploadError_FileType() {}

func (*FileUploadError_LogFileName) isFileUploadError_FileType() {}

type Environment struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Environment variables.
	Vars map[string]string `protobuf:"bytes,1,rep,name=vars,proto3" json:"vars,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	// Types that are valid to be assigned to DockerImage:
	//
	//	*Environment_DockerImageResourceId
	//	*Environment_DockerImageSpec
	DockerImage   isEnvironment_DockerImage `protobuf_oneof:"docker_image"`
	PythonEnv     *PythonEnv                `protobuf:"bytes,4,opt,name=python_env,json=pythonEnv,proto3" json:"python_env,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *Environment) Reset() {
	*x = Environment{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Environment) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Environment) ProtoMessage() {}

func (x *Environment) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Environment.ProtoReflect.Descriptor instead.
func (*Environment) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{8}
}

func (x *Environment) GetVars() map[string]string {
	if x != nil {
		return x.Vars
	}
	return nil
}

func (x *Environment) GetDockerImage() isEnvironment_DockerImage {
	if x != nil {
		return x.DockerImage
	}
	return nil
}

func (x *Environment) GetDockerImageResourceId() string {
	if x != nil {
		if x, ok := x.DockerImage.(*Environment_DockerImageResourceId); ok {
			return x.DockerImageResourceId
		}
	}
	return ""
}

func (x *Environment) GetDockerImageSpec() *DockerImageSpec {
	if x != nil {
		if x, ok := x.DockerImage.(*Environment_DockerImageSpec); ok {
			return x.DockerImageSpec
		}
	}
	return nil
}

func (x *Environment) GetPythonEnv() *PythonEnv {
	if x != nil {
		return x.PythonEnv
	}
	return nil
}

type isEnvironment_DockerImage interface {
	isEnvironment_DockerImage()
}

type Environment_DockerImageResourceId struct {
	// DS docker image id.
	DockerImageResourceId string `protobuf:"bytes,2,opt,name=docker_image_resource_id,json=dockerImageResourceId,proto3,oneof"`
}

type Environment_DockerImageSpec struct {
	DockerImageSpec *DockerImageSpec `protobuf:"bytes,3,opt,name=docker_image_spec,json=dockerImageSpec,proto3,oneof"`
}

func (*Environment_DockerImageResourceId) isEnvironment_DockerImage() {}

func (*Environment_DockerImageSpec) isEnvironment_DockerImage() {}

type DockerImageSpec struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Docker image URL.
	ImageUrl string `protobuf:"bytes,1,opt,name=image_url,json=imageUrl,proto3" json:"image_url,omitempty"`
	// Username for container registry.
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Password for container registry.
	//
	// Types that are valid to be assigned to Password:
	//
	//	*DockerImageSpec_PasswordPlainText
	//	*DockerImageSpec_PasswordDsSecretName
	Password      isDockerImageSpec_Password `protobuf_oneof:"password"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *DockerImageSpec) Reset() {
	*x = DockerImageSpec{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *DockerImageSpec) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*DockerImageSpec) ProtoMessage() {}

func (x *DockerImageSpec) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use DockerImageSpec.ProtoReflect.Descriptor instead.
func (*DockerImageSpec) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{9}
}

func (x *DockerImageSpec) GetImageUrl() string {
	if x != nil {
		return x.ImageUrl
	}
	return ""
}

func (x *DockerImageSpec) GetUsername() string {
	if x != nil {
		return x.Username
	}
	return ""
}

func (x *DockerImageSpec) GetPassword() isDockerImageSpec_Password {
	if x != nil {
		return x.Password
	}
	return nil
}

func (x *DockerImageSpec) GetPasswordPlainText() string {
	if x != nil {
		if x, ok := x.Password.(*DockerImageSpec_PasswordPlainText); ok {
			return x.PasswordPlainText
		}
	}
	return ""
}

func (x *DockerImageSpec) GetPasswordDsSecretName() string {
	if x != nil {
		if x, ok := x.Password.(*DockerImageSpec_PasswordDsSecretName); ok {
			return x.PasswordDsSecretName
		}
	}
	return ""
}

type isDockerImageSpec_Password interface {
	isDockerImageSpec_Password()
}

type DockerImageSpec_PasswordPlainText struct {
	// Plaintext password.
	PasswordPlainText string `protobuf:"bytes,3,opt,name=password_plain_text,json=passwordPlainText,proto3,oneof"`
}

type DockerImageSpec_PasswordDsSecretName struct {
	// ID of DataSphere secret containing password.
	PasswordDsSecretName string `protobuf:"bytes,4,opt,name=password_ds_secret_name,json=passwordDsSecretName,proto3,oneof"`
}

func (*DockerImageSpec_PasswordPlainText) isDockerImageSpec_Password() {}

func (*DockerImageSpec_PasswordDsSecretName) isDockerImageSpec_Password() {}

type PythonEnv struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Conda YAML.
	CondaYaml string `protobuf:"bytes,1,opt,name=conda_yaml,json=condaYaml,proto3" json:"conda_yaml,omitempty"`
	// List of local modules descriptions.
	LocalModules []*File `protobuf:"bytes,2,rep,name=local_modules,json=localModules,proto3" json:"local_modules,omitempty"`
	// Python version reduced to major.minor
	PythonVersion string `protobuf:"bytes,3,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"`
	// List of pip requirements
	Requirements []string `protobuf:"bytes,4,rep,name=requirements,proto3" json:"requirements,omitempty"`
	// Pip install options
	PipOptions    *PipOptions `protobuf:"bytes,5,opt,name=pip_options,json=pipOptions,proto3" json:"pip_options,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PythonEnv) Reset() {
	*x = PythonEnv{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PythonEnv) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PythonEnv) ProtoMessage() {}

func (x *PythonEnv) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[10]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use PythonEnv.ProtoReflect.Descriptor instead.
func (*PythonEnv) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{10}
}

func (x *PythonEnv) GetCondaYaml() string {
	if x != nil {
		return x.CondaYaml
	}
	return ""
}

func (x *PythonEnv) GetLocalModules() []*File {
	if x != nil {
		return x.LocalModules
	}
	return nil
}

func (x *PythonEnv) GetPythonVersion() string {
	if x != nil {
		return x.PythonVersion
	}
	return ""
}

func (x *PythonEnv) GetRequirements() []string {
	if x != nil {
		return x.Requirements
	}
	return nil
}

func (x *PythonEnv) GetPipOptions() *PipOptions {
	if x != nil {
		return x.PipOptions
	}
	return nil
}

type PipOptions struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// --index-url option
	IndexUrl string `protobuf:"bytes,1,opt,name=index_url,json=indexUrl,proto3" json:"index_url,omitempty"`
	// --extra-index-urls option
	ExtraIndexUrls []string `protobuf:"bytes,2,rep,name=extra_index_urls,json=extraIndexUrls,proto3" json:"extra_index_urls,omitempty"`
	// --trusted-hosts option
	TrustedHosts []string `protobuf:"bytes,3,rep,name=trusted_hosts,json=trustedHosts,proto3" json:"trusted_hosts,omitempty"`
	// --no-deps option
	NoDeps        bool `protobuf:"varint,4,opt,name=no_deps,json=noDeps,proto3" json:"no_deps,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *PipOptions) Reset() {
	*x = PipOptions{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *PipOptions) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*PipOptions) ProtoMessage() {}

func (x *PipOptions) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[11]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use PipOptions.ProtoReflect.Descriptor instead.
func (*PipOptions) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{11}
}

func (x *PipOptions) GetIndexUrl() string {
	if x != nil {
		return x.IndexUrl
	}
	return ""
}

func (x *PipOptions) GetExtraIndexUrls() []string {
	if x != nil {
		return x.ExtraIndexUrls
	}
	return nil
}

func (x *PipOptions) GetTrustedHosts() []string {
	if x != nil {
		return x.TrustedHosts
	}
	return nil
}

func (x *PipOptions) GetNoDeps() bool {
	if x != nil {
		return x.NoDeps
	}
	return false
}

type OutputDatasetDesc struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Name to create dataset with
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description to show in UI
	Description string            `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Labels      map[string]string `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	// Size of dataset to create
	SizeGb int64 `protobuf:"varint,4,opt,name=size_gb,json=sizeGb,proto3" json:"size_gb,omitempty"`
	// Var name to replace in cmd, like in FileDesc
	Var           string `protobuf:"bytes,5,opt,name=var,proto3" json:"var,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *OutputDatasetDesc) Reset() {
	*x = OutputDatasetDesc{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *OutputDatasetDesc) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*OutputDatasetDesc) ProtoMessage() {}

func (x *OutputDatasetDesc) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[12]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use OutputDatasetDesc.ProtoReflect.Descriptor instead.
func (*OutputDatasetDesc) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{12}
}

func (x *OutputDatasetDesc) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *OutputDatasetDesc) GetDescription() string {
	if x != nil {
		return x.Description
	}
	return ""
}

func (x *OutputDatasetDesc) GetLabels() map[string]string {
	if x != nil {
		return x.Labels
	}
	return nil
}

func (x *OutputDatasetDesc) GetSizeGb() int64 {
	if x != nil {
		return x.SizeGb
	}
	return 0
}

func (x *OutputDatasetDesc) GetVar() string {
	if x != nil {
		return x.Var
	}
	return ""
}

type OutputDataset struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Dataset description
	Desc *OutputDatasetDesc `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
	// Id of created dataset
	Id            string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *OutputDataset) Reset() {
	*x = OutputDataset{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *OutputDataset) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*OutputDataset) ProtoMessage() {}

func (x *OutputDataset) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[13]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use OutputDataset.ProtoReflect.Descriptor instead.
func (*OutputDataset) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{13}
}

func (x *OutputDataset) GetDesc() *OutputDatasetDesc {
	if x != nil {
		return x.Desc
	}
	return nil
}

func (x *OutputDataset) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

// Instance of the job.
type Job struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// ID of the job.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the job.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the job.
	Desc string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// Create job timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Finish job timestamp.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Status of the job.
	Status JobStatus `protobuf:"varint,6,opt,name=status,proto3,enum=yandex.cloud.datasphere.v2.jobs.JobStatus" json:"status,omitempty"`
	// Config of the job, copied from configuration file.
	Config string `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	// ID of the user who created the job.
	CreatedById string `protobuf:"bytes,8,opt,name=created_by_id,json=createdById,proto3" json:"created_by_id,omitempty"`
	// ID of the project.
	ProjectId     string         `protobuf:"bytes,9,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	JobParameters *JobParameters `protobuf:"bytes,10,opt,name=job_parameters,json=jobParameters,proto3" json:"job_parameters,omitempty"`
	// Job data expiration timestamp.
	DataExpiresAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=data_expires_at,json=dataExpiresAt,proto3" json:"data_expires_at,omitempty"`
	// Marks if the job data has been cleared.
	DataCleared bool `protobuf:"varint,12,opt,name=data_cleared,json=dataCleared,proto3" json:"data_cleared,omitempty"`
	// Output files of the job.
	OutputFiles []*File `protobuf:"bytes,13,rep,name=output_files,json=outputFiles,proto3" json:"output_files,omitempty"`
	// Job log files.
	LogFiles []*File `protobuf:"bytes,14,rep,name=log_files,json=logFiles,proto3" json:"log_files,omitempty"`
	// Job diagnostics files.
	DiagnosticFiles []*File `protobuf:"bytes,15,rep,name=diagnostic_files,json=diagnosticFiles,proto3" json:"diagnostic_files,omitempty"`
	// Job total data size.
	DataSizeBytes int64 `protobuf:"varint,16,opt,name=data_size_bytes,json=dataSizeBytes,proto3" json:"data_size_bytes,omitempty"`
	// Start job timestamp.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,17,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Details.
	StatusDetails string `protobuf:"bytes,18,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
	// Actual VM instance type, job is running on.
	ActualCloudInstanceType *CloudInstanceType `protobuf:"bytes,19,opt,name=actual_cloud_instance_type,json=actualCloudInstanceType,proto3" json:"actual_cloud_instance_type,omitempty"`
	// Reference to the parent job.
	ParentJobId string `protobuf:"bytes,20,opt,name=parent_job_id,json=parentJobId,proto3" json:"parent_job_id,omitempty"`
	// Failed uploads.
	FileErrors []*FileUploadError `protobuf:"bytes,21,rep,name=file_errors,json=fileErrors,proto3" json:"file_errors,omitempty"`
	// Created datasets.
	OutputDatasets []*OutputDataset `protobuf:"bytes,22,rep,name=output_datasets,json=outputDatasets,proto3" json:"output_datasets,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *Job) Reset() {
	*x = Job{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *Job) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*Job) ProtoMessage() {}

func (x *Job) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[14]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use Job.ProtoReflect.Descriptor instead.
func (*Job) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{14}
}

func (x *Job) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *Job) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *Job) GetDesc() string {
	if x != nil {
		return x.Desc
	}
	return ""
}

func (x *Job) GetCreatedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.CreatedAt
	}
	return nil
}

func (x *Job) GetFinishedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.FinishedAt
	}
	return nil
}

func (x *Job) GetStatus() JobStatus {
	if x != nil {
		return x.Status
	}
	return JobStatus_JOB_STATUS_UNSPECIFIED
}

func (x *Job) GetConfig() string {
	if x != nil {
		return x.Config
	}
	return ""
}

func (x *Job) GetCreatedById() string {
	if x != nil {
		return x.CreatedById
	}
	return ""
}

func (x *Job) GetProjectId() string {
	if x != nil {
		return x.ProjectId
	}
	return ""
}

func (x *Job) GetJobParameters() *JobParameters {
	if x != nil {
		return x.JobParameters
	}
	return nil
}

func (x *Job) GetDataExpiresAt() *timestamppb.Timestamp {
	if x != nil {
		return x.DataExpiresAt
	}
	return nil
}

func (x *Job) GetDataCleared() bool {
	if x != nil {
		return x.DataCleared
	}
	return false
}

func (x *Job) GetOutputFiles() []*File {
	if x != nil {
		return x.OutputFiles
	}
	return nil
}

func (x *Job) GetLogFiles() []*File {
	if x != nil {
		return x.LogFiles
	}
	return nil
}

func (x *Job) GetDiagnosticFiles() []*File {
	if x != nil {
		return x.DiagnosticFiles
	}
	return nil
}

func (x *Job) GetDataSizeBytes() int64 {
	if x != nil {
		return x.DataSizeBytes
	}
	return 0
}

func (x *Job) GetStartedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.StartedAt
	}
	return nil
}

func (x *Job) GetStatusDetails() string {
	if x != nil {
		return x.StatusDetails
	}
	return ""
}

func (x *Job) GetActualCloudInstanceType() *CloudInstanceType {
	if x != nil {
		return x.ActualCloudInstanceType
	}
	return nil
}

func (x *Job) GetParentJobId() string {
	if x != nil {
		return x.ParentJobId
	}
	return ""
}

func (x *Job) GetFileErrors() []*FileUploadError {
	if x != nil {
		return x.FileErrors
	}
	return nil
}

func (x *Job) GetOutputDatasets() []*OutputDataset {
	if x != nil {
		return x.OutputDatasets
	}
	return nil
}

type JobResult struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Execution return code.
	ReturnCode    int64 `protobuf:"varint,1,opt,name=return_code,json=returnCode,proto3" json:"return_code,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JobResult) Reset() {
	*x = JobResult{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JobResult) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JobResult) ProtoMessage() {}

func (x *JobResult) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[15]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use JobResult.ProtoReflect.Descriptor instead.
func (*JobResult) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{15}
}

func (x *JobResult) GetReturnCode() int64 {
	if x != nil {
		return x.ReturnCode
	}
	return 0
}

type GracefulShutdownParameters struct {
	state   protoimpl.MessageState `protogen:"open.v1"`
	Timeout *durationpb.Duration   `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// default 15 (SIGTERM)
	Signal        int64 `protobuf:"varint,2,opt,name=signal,proto3" json:"signal,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GracefulShutdownParameters) Reset() {
	*x = GracefulShutdownParameters{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GracefulShutdownParameters) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GracefulShutdownParameters) ProtoMessage() {}

func (x *GracefulShutdownParameters) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[16]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GracefulShutdownParameters.ProtoReflect.Descriptor instead.
func (*GracefulShutdownParameters) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{16}
}

func (x *GracefulShutdownParameters) GetTimeout() *durationpb.Duration {
	if x != nil {
		return x.Timeout
	}
	return nil
}

func (x *GracefulShutdownParameters) GetSignal() int64 {
	if x != nil {
		return x.Signal
	}
	return 0
}

type JobMetadata struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// ID of the job.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the job.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the job.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Create job timestamp.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Start job timestamp.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// Finish job timestamp.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Job data expiration timestamp.
	DataExpiresAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=data_expires_at,json=dataExpiresAt,proto3" json:"data_expires_at,omitempty"`
	// Status of the job.
	Status JobStatus `protobuf:"varint,8,opt,name=status,proto3,enum=yandex.cloud.datasphere.v2.jobs.JobStatus" json:"status,omitempty"`
	// Details.
	StatusDetails string `protobuf:"bytes,9,opt,name=status_details,json=statusDetails,proto3" json:"status_details,omitempty"`
	// ID of the user who created the job.
	CreatedById string `protobuf:"bytes,10,opt,name=created_by_id,json=createdById,proto3" json:"created_by_id,omitempty"`
	// ID of the project.
	ProjectId string `protobuf:"bytes,11,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Reference to the parent job.
	ParentJobId   string `protobuf:"bytes,12,opt,name=parent_job_id,json=parentJobId,proto3" json:"parent_job_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JobMetadata) Reset() {
	*x = JobMetadata{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JobMetadata) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JobMetadata) ProtoMessage() {}

func (x *JobMetadata) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[17]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use JobMetadata.ProtoReflect.Descriptor instead.
func (*JobMetadata) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{17}
}

func (x *JobMetadata) GetId() string {
	if x != nil {
		return x.Id
	}
	return ""
}

func (x *JobMetadata) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *JobMetadata) GetDescription() string {
	if x != nil {
		return x.Description
	}
	return ""
}

func (x *JobMetadata) GetCreatedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.CreatedAt
	}
	return nil
}

func (x *JobMetadata) GetStartedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.StartedAt
	}
	return nil
}

func (x *JobMetadata) GetFinishedAt() *timestamppb.Timestamp {
	if x != nil {
		return x.FinishedAt
	}
	return nil
}

func (x *JobMetadata) GetDataExpiresAt() *timestamppb.Timestamp {
	if x != nil {
		return x.DataExpiresAt
	}
	return nil
}

func (x *JobMetadata) GetStatus() JobStatus {
	if x != nil {
		return x.Status
	}
	return JobStatus_JOB_STATUS_UNSPECIFIED
}

func (x *JobMetadata) GetStatusDetails() string {
	if x != nil {
		return x.StatusDetails
	}
	return ""
}

func (x *JobMetadata) GetCreatedById() string {
	if x != nil {
		return x.CreatedById
	}
	return ""
}

func (x *JobMetadata) GetProjectId() string {
	if x != nil {
		return x.ProjectId
	}
	return ""
}

func (x *JobMetadata) GetParentJobId() string {
	if x != nil {
		return x.ParentJobId
	}
	return ""
}

type JobProgress struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Progress message
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// Progress of the job from 0 to 100
	Progress int64 `protobuf:"varint,2,opt,name=progress,proto3" json:"progress,omitempty"`
	// Progress create time
	CreateTime    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *JobProgress) Reset() {
	*x = JobProgress{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *JobProgress) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*JobProgress) ProtoMessage() {}

func (x *JobProgress) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[18]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use JobProgress.ProtoReflect.Descriptor instead.
func (*JobProgress) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{18}
}

func (x *JobProgress) GetMessage() string {
	if x != nil {
		return x.Message
	}
	return ""
}

func (x *JobProgress) GetProgress() int64 {
	if x != nil {
		return x.Progress
	}
	return 0
}

func (x *JobProgress) GetCreateTime() *timestamppb.Timestamp {
	if x != nil {
		return x.CreateTime
	}
	return nil
}

type SparkParameters struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// ID of the Spark connector.
	ConnectorId   string `protobuf:"bytes,1,opt,name=connector_id,json=connectorId,proto3" json:"connector_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SparkParameters) Reset() {
	*x = SparkParameters{}
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SparkParameters) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SparkParameters) ProtoMessage() {}

func (x *SparkParameters) ProtoReflect() protoreflect.Message {
	mi := &file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[19]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SparkParameters.ProtoReflect.Descriptor instead.
func (*SparkParameters) Descriptor() ([]byte, []int) {
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP(), []int{19}
}

func (x *SparkParameters) GetConnectorId() string {
	if x != nil {
		return x.ConnectorId
	}
	return ""
}

var File_yandex_cloud_datasphere_v2_jobs_jobs_proto protoreflect.FileDescriptor

const file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDesc = "" +
	"\n" +
	"*yandex/cloud/datasphere/v2/jobs/jobs.proto\x12\x1fyandex.cloud.datasphere.v2.jobs\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1dyandex/cloud/validation.proto\x1a\x1egoogle/protobuf/duration.proto\"\xce\a\n" +
	"\rJobParameters\x12F\n" +
	"\vinput_files\x18\x01 \x03(\v2%.yandex.cloud.datasphere.v2.jobs.FileR\n" +
	"inputFiles\x12L\n" +
	"\foutput_files\x18\x02 \x03(\v2).yandex.cloud.datasphere.v2.jobs.FileDescR\voutputFiles\x12 \n" +
	"\fs3_mount_ids\x18\x03 \x03(\tR\n" +
	"s3MountIds\x12\x1f\n" +
	"\vdataset_ids\x18\x04 \x03(\tR\n" +
	"datasetIds\x12\x10\n" +
	"\x03cmd\x18\x05 \x01(\tR\x03cmd\x12>\n" +
	"\x03env\x18\x06 \x01(\v2,.yandex.cloud.datasphere.v2.jobs.EnvironmentR\x03env\x12.\n" +
	"\x13attach_project_disk\x18\a \x01(\bR\x11attachProjectDisk\x12m\n" +
	"\x14cloud_instance_types\x18\b \x03(\v22.yandex.cloud.datasphere.v2.jobs.CloudInstanceTypeB\a\x82\xc81\x03>=1R\x12cloudInstanceTypes\x12q\n" +
	"\x18extended_working_storage\x18\t \x01(\v27.yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorageR\x16extendedWorkingStorage\x12G\n" +
	"\targuments\x18\n" +
	" \x03(\v2).yandex.cloud.datasphere.v2.jobs.ArgumentR\targuments\x12[\n" +
	"\x0foutput_datasets\x18\v \x03(\v22.yandex.cloud.datasphere.v2.jobs.OutputDatasetDescR\x0eoutputDatasets\x12}\n" +
	"\x1cgraceful_shutdown_parameters\x18\f \x01(\v2;.yandex.cloud.datasphere.v2.jobs.GracefulShutdownParametersR\x1agracefulShutdownParameters\x12[\n" +
	"\x10spark_parameters\x18\r \x01(\v20.yandex.cloud.datasphere.v2.jobs.SparkParametersR\x0fsparkParameters\"'\n" +
	"\x11CloudInstanceType\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\"\xc0\x01\n" +
	"\x16ExtendedWorkingStorage\x12W\n" +
	"\x04type\x18\x01 \x01(\x0e2C.yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage.StorageTypeR\x04type\x12\x17\n" +
	"\asize_gb\x18\x02 \x01(\x03R\x06sizeGb\"4\n" +
	"\vStorageType\x12\x1c\n" +
	"\x18STORAGE_TYPE_UNSPECIFIED\x10\x00\x12\a\n" +
	"\x03SSD\x10\x01\"4\n" +
	"\bArgument\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value\"\xdd\x01\n" +
	"\x04File\x12=\n" +
	"\x04desc\x18\x01 \x01(\v2).yandex.cloud.datasphere.v2.jobs.FileDescR\x04desc\x12\x16\n" +
	"\x06sha256\x18\x02 \x01(\tR\x06sha256\x12\x1d\n" +
	"\n" +
	"size_bytes\x18\x03 \x01(\x03R\tsizeBytes\x12_\n" +
	"\x10compression_type\x18\x04 \x01(\x0e24.yandex.cloud.datasphere.v2.jobs.FileCompressionTypeR\x0fcompressionType\"Z\n" +
	"\vStorageFile\x129\n" +
	"\x04file\x18\x01 \x01(\v2%.yandex.cloud.datasphere.v2.jobs.FileR\x04file\x12\x10\n" +
	"\x03url\x18\x02 \x01(\tR\x03url\"0\n" +
	"\bFileDesc\x12\x12\n" +
	"\x04path\x18\x01 \x01(\tR\x04path\x12\x10\n" +
	"\x03var\x18\x02 \x01(\tR\x03var\"\xd8\x02\n" +
	"\x0fFileUploadError\x12U\n" +
	"\x10output_file_desc\x18\x01 \x01(\v2).yandex.cloud.datasphere.v2.jobs.FileDescH\x00R\x0eoutputFileDesc\x12$\n" +
	"\rlog_file_name\x18\x02 \x01(\tH\x00R\vlogFileName\x12 \n" +
	"\vdescription\x18\x03 \x01(\tR\vdescription\x12N\n" +
	"\x04type\x18\x04 \x01(\x0e2:.yandex.cloud.datasphere.v2.jobs.FileUploadError.ErrorTypeR\x04type\"I\n" +
	"\tErrorType\x12\x1a\n" +
	"\x16ERROR_TYPE_UNSPECIFIED\x10\x00\x12\x11\n" +
	"\rUPLOAD_FAILED\x10\x01\x12\r\n" +
	"\tNOT_FOUND\x10\x02B\v\n" +
	"\tfile_type\"\x88\x03\n" +
	"\vEnvironment\x12J\n" +
	"\x04vars\x18\x01 \x03(\v26.yandex.cloud.datasphere.v2.jobs.Environment.VarsEntryR\x04vars\x129\n" +
	"\x18docker_image_resource_id\x18\x02 \x01(\tH\x00R\x15dockerImageResourceId\x12^\n" +
	"\x11docker_image_spec\x18\x03 \x01(\v20.yandex.cloud.datasphere.v2.jobs.DockerImageSpecH\x00R\x0fdockerImageSpec\x12I\n" +
	"\n" +
	"python_env\x18\x04 \x01(\v2*.yandex.cloud.datasphere.v2.jobs.PythonEnvR\tpythonEnv\x1a7\n" +
	"\tVarsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01B\x0e\n" +
	"\fdocker_image\"\xc1\x01\n" +
	"\x0fDockerImageSpec\x12\x1b\n" +
	"\timage_url\x18\x01 \x01(\tR\bimageUrl\x12\x1a\n" +
	"\busername\x18\x02 \x01(\tR\busername\x120\n" +
	"\x13password_plain_text\x18\x03 \x01(\tH\x00R\x11passwordPlainText\x127\n" +
	"\x17password_ds_secret_name\x18\x04 \x01(\tH\x00R\x14passwordDsSecretNameB\n" +
	"\n" +
	"\bpassword\"\x8f\x02\n" +
	"\tPythonEnv\x12\x1d\n" +
	"\n" +
	"conda_yaml\x18\x01 \x01(\tR\tcondaYaml\x12J\n" +
	"\rlocal_modules\x18\x02 \x03(\v2%.yandex.cloud.datasphere.v2.jobs.FileR\flocalModules\x12%\n" +
	"\x0epython_version\x18\x03 \x01(\tR\rpythonVersion\x12\"\n" +
	"\frequirements\x18\x04 \x03(\tR\frequirements\x12L\n" +
	"\vpip_options\x18\x05 \x01(\v2+.yandex.cloud.datasphere.v2.jobs.PipOptionsR\n" +
	"pipOptions\"\x91\x01\n" +
	"\n" +
	"PipOptions\x12\x1b\n" +
	"\tindex_url\x18\x01 \x01(\tR\bindexUrl\x12(\n" +
	"\x10extra_index_urls\x18\x02 \x03(\tR\x0eextraIndexUrls\x12#\n" +
	"\rtrusted_hosts\x18\x03 \x03(\tR\ftrustedHosts\x12\x17\n" +
	"\ano_deps\x18\x04 \x01(\bR\x06noDeps\"\x87\x02\n" +
	"\x11OutputDatasetDesc\x12\x12\n" +
	"\x04name\x18\x01 \x01(\tR\x04name\x12 \n" +
	"\vdescription\x18\x02 \x01(\tR\vdescription\x12V\n" +
	"\x06labels\x18\x03 \x03(\v2>.yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc.LabelsEntryR\x06labels\x12\x17\n" +
	"\asize_gb\x18\x04 \x01(\x03R\x06sizeGb\x12\x10\n" +
	"\x03var\x18\x05 \x01(\tR\x03var\x1a9\n" +
	"\vLabelsEntry\x12\x10\n" +
	"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
	"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"g\n" +
	"\rOutputDataset\x12F\n" +
	"\x04desc\x18\x01 \x01(\v22.yandex.cloud.datasphere.v2.jobs.OutputDatasetDescR\x04desc\x12\x0e\n" +
	"\x02id\x18\x02 \x01(\tR\x02id\"\xbd\t\n" +
	"\x03Job\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x12\n" +
	"\x04name\x18\x02 \x01(\tR\x04name\x12\x12\n" +
	"\x04desc\x18\x03 \x01(\tR\x04desc\x129\n" +
	"\n" +
	"created_at\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x12;\n" +
	"\vfinished_at\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
	"finishedAt\x12B\n" +
	"\x06status\x18\x06 \x01(\x0e2*.yandex.cloud.datasphere.v2.jobs.JobStatusR\x06status\x12\x16\n" +
	"\x06config\x18\a \x01(\tR\x06config\x12\"\n" +
	"\rcreated_by_id\x18\b \x01(\tR\vcreatedById\x12\x1d\n" +
	"\n" +
	"project_id\x18\t \x01(\tR\tprojectId\x12U\n" +
	"\x0ejob_parameters\x18\n" +
	" \x01(\v2..yandex.cloud.datasphere.v2.jobs.JobParametersR\rjobParameters\x12B\n" +
	"\x0fdata_expires_at\x18\v \x01(\v2\x1a.google.protobuf.TimestampR\rdataExpiresAt\x12!\n" +
	"\fdata_cleared\x18\f \x01(\bR\vdataCleared\x12H\n" +
	"\foutput_files\x18\r \x03(\v2%.yandex.cloud.datasphere.v2.jobs.FileR\voutputFiles\x12B\n" +
	"\tlog_files\x18\x0e \x03(\v2%.yandex.cloud.datasphere.v2.jobs.FileR\blogFiles\x12P\n" +
	"\x10diagnostic_files\x18\x0f \x03(\v2%.yandex.cloud.datasphere.v2.jobs.FileR\x0fdiagnosticFiles\x12&\n" +
	"\x0fdata_size_bytes\x18\x10 \x01(\x03R\rdataSizeBytes\x129\n" +
	"\n" +
	"started_at\x18\x11 \x01(\v2\x1a.google.protobuf.TimestampR\tstartedAt\x12%\n" +
	"\x0estatus_details\x18\x12 \x01(\tR\rstatusDetails\x12o\n" +
	"\x1aactual_cloud_instance_type\x18\x13 \x01(\v22.yandex.cloud.datasphere.v2.jobs.CloudInstanceTypeR\x17actualCloudInstanceType\x12\"\n" +
	"\rparent_job_id\x18\x14 \x01(\tR\vparentJobId\x12Q\n" +
	"\vfile_errors\x18\x15 \x03(\v20.yandex.cloud.datasphere.v2.jobs.FileUploadErrorR\n" +
	"fileErrors\x12W\n" +
	"\x0foutput_datasets\x18\x16 \x03(\v2..yandex.cloud.datasphere.v2.jobs.OutputDatasetR\x0eoutputDatasets\",\n" +
	"\tJobResult\x12\x1f\n" +
	"\vreturn_code\x18\x01 \x01(\x03R\n" +
	"returnCode\"i\n" +
	"\x1aGracefulShutdownParameters\x123\n" +
	"\atimeout\x18\x01 \x01(\v2\x19.google.protobuf.DurationR\atimeout\x12\x16\n" +
	"\x06signal\x18\x02 \x01(\x03R\x06signal\"\x9c\x04\n" +
	"\vJobMetadata\x12\x0e\n" +
	"\x02id\x18\x01 \x01(\tR\x02id\x12\x12\n" +
	"\x04name\x18\x02 \x01(\tR\x04name\x12 \n" +
	"\vdescription\x18\x03 \x01(\tR\vdescription\x129\n" +
	"\n" +
	"created_at\x18\x04 \x01(\v2\x1a.google.protobuf.TimestampR\tcreatedAt\x129\n" +
	"\n" +
	"started_at\x18\x05 \x01(\v2\x1a.google.protobuf.TimestampR\tstartedAt\x12;\n" +
	"\vfinished_at\x18\x06 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
	"finishedAt\x12B\n" +
	"\x0fdata_expires_at\x18\a \x01(\v2\x1a.google.protobuf.TimestampR\rdataExpiresAt\x12B\n" +
	"\x06status\x18\b \x01(\x0e2*.yandex.cloud.datasphere.v2.jobs.JobStatusR\x06status\x12%\n" +
	"\x0estatus_details\x18\t \x01(\tR\rstatusDetails\x12\"\n" +
	"\rcreated_by_id\x18\n" +
	" \x01(\tR\vcreatedById\x12\x1d\n" +
	"\n" +
	"project_id\x18\v \x01(\tR\tprojectId\x12\"\n" +
	"\rparent_job_id\x18\f \x01(\tR\vparentJobId\"\x80\x01\n" +
	"\vJobProgress\x12\x18\n" +
	"\amessage\x18\x01 \x01(\tR\amessage\x12\x1a\n" +
	"\bprogress\x18\x02 \x01(\x03R\bprogress\x12;\n" +
	"\vcreate_time\x18\x03 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
	"createTime\"4\n" +
	"\x0fSparkParameters\x12!\n" +
	"\fconnector_id\x18\x01 \x01(\tR\vconnectorId*O\n" +
	"\x13FileCompressionType\x12%\n" +
	"!FILE_COMPRESSION_TYPE_UNSPECIFIED\x10\x00\x12\b\n" +
	"\x04NONE\x10\x01\x12\a\n" +
	"\x03ZIP\x10\x02*\xa0\x01\n" +
	"\tJobStatus\x12\x1a\n" +
	"\x16JOB_STATUS_UNSPECIFIED\x10\x00\x12\f\n" +
	"\bCREATING\x10\x01\x12\r\n" +
	"\tEXECUTING\x10\x02\x12\x14\n" +
	"\x10UPLOADING_OUTPUT\x10\x03\x12\v\n" +
	"\aSUCCESS\x10\x04\x12\t\n" +
	"\x05ERROR\x10\x05\x12\r\n" +
	"\tCANCELLED\x10\x06\x12\x0e\n" +
	"\n" +
	"CANCELLING\x10\a\x12\r\n" +
	"\tPREPARING\x10\bB{\n" +
	"#yandex.cloud.api.datasphere.v2.jobsB\x04JobsZNgithub.com/yandex-cloud/go-genproto/yandex/cloud/datasphere/v2/jobs;datasphereb\x06proto3"

var (
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescOnce sync.Once
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescData []byte
)

func file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescGZIP() []byte {
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescOnce.Do(func() {
		file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDesc), len(file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDesc)))
	})
	return file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDescData
}

var file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
var file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes = make([]protoimpl.MessageInfo, 22)
var file_yandex_cloud_datasphere_v2_jobs_jobs_proto_goTypes = []any{
	(FileCompressionType)(0),                // 0: yandex.cloud.datasphere.v2.jobs.FileCompressionType
	(JobStatus)(0),                          // 1: yandex.cloud.datasphere.v2.jobs.JobStatus
	(ExtendedWorkingStorage_StorageType)(0), // 2: yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage.StorageType
	(FileUploadError_ErrorType)(0),          // 3: yandex.cloud.datasphere.v2.jobs.FileUploadError.ErrorType
	(*JobParameters)(nil),                   // 4: yandex.cloud.datasphere.v2.jobs.JobParameters
	(*CloudInstanceType)(nil),               // 5: yandex.cloud.datasphere.v2.jobs.CloudInstanceType
	(*ExtendedWorkingStorage)(nil),          // 6: yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage
	(*Argument)(nil),                        // 7: yandex.cloud.datasphere.v2.jobs.Argument
	(*File)(nil),                            // 8: yandex.cloud.datasphere.v2.jobs.File
	(*StorageFile)(nil),                     // 9: yandex.cloud.datasphere.v2.jobs.StorageFile
	(*FileDesc)(nil),                        // 10: yandex.cloud.datasphere.v2.jobs.FileDesc
	(*FileUploadError)(nil),                 // 11: yandex.cloud.datasphere.v2.jobs.FileUploadError
	(*Environment)(nil),                     // 12: yandex.cloud.datasphere.v2.jobs.Environment
	(*DockerImageSpec)(nil),                 // 13: yandex.cloud.datasphere.v2.jobs.DockerImageSpec
	(*PythonEnv)(nil),                       // 14: yandex.cloud.datasphere.v2.jobs.PythonEnv
	(*PipOptions)(nil),                      // 15: yandex.cloud.datasphere.v2.jobs.PipOptions
	(*OutputDatasetDesc)(nil),               // 16: yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc
	(*OutputDataset)(nil),                   // 17: yandex.cloud.datasphere.v2.jobs.OutputDataset
	(*Job)(nil),                             // 18: yandex.cloud.datasphere.v2.jobs.Job
	(*JobResult)(nil),                       // 19: yandex.cloud.datasphere.v2.jobs.JobResult
	(*GracefulShutdownParameters)(nil),      // 20: yandex.cloud.datasphere.v2.jobs.GracefulShutdownParameters
	(*JobMetadata)(nil),                     // 21: yandex.cloud.datasphere.v2.jobs.JobMetadata
	(*JobProgress)(nil),                     // 22: yandex.cloud.datasphere.v2.jobs.JobProgress
	(*SparkParameters)(nil),                 // 23: yandex.cloud.datasphere.v2.jobs.SparkParameters
	nil,                                     // 24: yandex.cloud.datasphere.v2.jobs.Environment.VarsEntry
	nil,                                     // 25: yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc.LabelsEntry
	(*timestamppb.Timestamp)(nil),           // 26: google.protobuf.Timestamp
	(*durationpb.Duration)(nil),             // 27: google.protobuf.Duration
}
var file_yandex_cloud_datasphere_v2_jobs_jobs_proto_depIdxs = []int32{
	8,  // 0: yandex.cloud.datasphere.v2.jobs.JobParameters.input_files:type_name -> yandex.cloud.datasphere.v2.jobs.File
	10, // 1: yandex.cloud.datasphere.v2.jobs.JobParameters.output_files:type_name -> yandex.cloud.datasphere.v2.jobs.FileDesc
	12, // 2: yandex.cloud.datasphere.v2.jobs.JobParameters.env:type_name -> yandex.cloud.datasphere.v2.jobs.Environment
	5,  // 3: yandex.cloud.datasphere.v2.jobs.JobParameters.cloud_instance_types:type_name -> yandex.cloud.datasphere.v2.jobs.CloudInstanceType
	6,  // 4: yandex.cloud.datasphere.v2.jobs.JobParameters.extended_working_storage:type_name -> yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage
	7,  // 5: yandex.cloud.datasphere.v2.jobs.JobParameters.arguments:type_name -> yandex.cloud.datasphere.v2.jobs.Argument
	16, // 6: yandex.cloud.datasphere.v2.jobs.JobParameters.output_datasets:type_name -> yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc
	20, // 7: yandex.cloud.datasphere.v2.jobs.JobParameters.graceful_shutdown_parameters:type_name -> yandex.cloud.datasphere.v2.jobs.GracefulShutdownParameters
	23, // 8: yandex.cloud.datasphere.v2.jobs.JobParameters.spark_parameters:type_name -> yandex.cloud.datasphere.v2.jobs.SparkParameters
	2,  // 9: yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage.type:type_name -> yandex.cloud.datasphere.v2.jobs.ExtendedWorkingStorage.StorageType
	10, // 10: yandex.cloud.datasphere.v2.jobs.File.desc:type_name -> yandex.cloud.datasphere.v2.jobs.FileDesc
	0,  // 11: yandex.cloud.datasphere.v2.jobs.File.compression_type:type_name -> yandex.cloud.datasphere.v2.jobs.FileCompressionType
	8,  // 12: yandex.cloud.datasphere.v2.jobs.StorageFile.file:type_name -> yandex.cloud.datasphere.v2.jobs.File
	10, // 13: yandex.cloud.datasphere.v2.jobs.FileUploadError.output_file_desc:type_name -> yandex.cloud.datasphere.v2.jobs.FileDesc
	3,  // 14: yandex.cloud.datasphere.v2.jobs.FileUploadError.type:type_name -> yandex.cloud.datasphere.v2.jobs.FileUploadError.ErrorType
	24, // 15: yandex.cloud.datasphere.v2.jobs.Environment.vars:type_name -> yandex.cloud.datasphere.v2.jobs.Environment.VarsEntry
	13, // 16: yandex.cloud.datasphere.v2.jobs.Environment.docker_image_spec:type_name -> yandex.cloud.datasphere.v2.jobs.DockerImageSpec
	14, // 17: yandex.cloud.datasphere.v2.jobs.Environment.python_env:type_name -> yandex.cloud.datasphere.v2.jobs.PythonEnv
	8,  // 18: yandex.cloud.datasphere.v2.jobs.PythonEnv.local_modules:type_name -> yandex.cloud.datasphere.v2.jobs.File
	15, // 19: yandex.cloud.datasphere.v2.jobs.PythonEnv.pip_options:type_name -> yandex.cloud.datasphere.v2.jobs.PipOptions
	25, // 20: yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc.labels:type_name -> yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc.LabelsEntry
	16, // 21: yandex.cloud.datasphere.v2.jobs.OutputDataset.desc:type_name -> yandex.cloud.datasphere.v2.jobs.OutputDatasetDesc
	26, // 22: yandex.cloud.datasphere.v2.jobs.Job.created_at:type_name -> google.protobuf.Timestamp
	26, // 23: yandex.cloud.datasphere.v2.jobs.Job.finished_at:type_name -> google.protobuf.Timestamp
	1,  // 24: yandex.cloud.datasphere.v2.jobs.Job.status:type_name -> yandex.cloud.datasphere.v2.jobs.JobStatus
	4,  // 25: yandex.cloud.datasphere.v2.jobs.Job.job_parameters:type_name -> yandex.cloud.datasphere.v2.jobs.JobParameters
	26, // 26: yandex.cloud.datasphere.v2.jobs.Job.data_expires_at:type_name -> google.protobuf.Timestamp
	8,  // 27: yandex.cloud.datasphere.v2.jobs.Job.output_files:type_name -> yandex.cloud.datasphere.v2.jobs.File
	8,  // 28: yandex.cloud.datasphere.v2.jobs.Job.log_files:type_name -> yandex.cloud.datasphere.v2.jobs.File
	8,  // 29: yandex.cloud.datasphere.v2.jobs.Job.diagnostic_files:type_name -> yandex.cloud.datasphere.v2.jobs.File
	26, // 30: yandex.cloud.datasphere.v2.jobs.Job.started_at:type_name -> google.protobuf.Timestamp
	5,  // 31: yandex.cloud.datasphere.v2.jobs.Job.actual_cloud_instance_type:type_name -> yandex.cloud.datasphere.v2.jobs.CloudInstanceType
	11, // 32: yandex.cloud.datasphere.v2.jobs.Job.file_errors:type_name -> yandex.cloud.datasphere.v2.jobs.FileUploadError
	17, // 33: yandex.cloud.datasphere.v2.jobs.Job.output_datasets:type_name -> yandex.cloud.datasphere.v2.jobs.OutputDataset
	27, // 34: yandex.cloud.datasphere.v2.jobs.GracefulShutdownParameters.timeout:type_name -> google.protobuf.Duration
	26, // 35: yandex.cloud.datasphere.v2.jobs.JobMetadata.created_at:type_name -> google.protobuf.Timestamp
	26, // 36: yandex.cloud.datasphere.v2.jobs.JobMetadata.started_at:type_name -> google.protobuf.Timestamp
	26, // 37: yandex.cloud.datasphere.v2.jobs.JobMetadata.finished_at:type_name -> google.protobuf.Timestamp
	26, // 38: yandex.cloud.datasphere.v2.jobs.JobMetadata.data_expires_at:type_name -> google.protobuf.Timestamp
	1,  // 39: yandex.cloud.datasphere.v2.jobs.JobMetadata.status:type_name -> yandex.cloud.datasphere.v2.jobs.JobStatus
	26, // 40: yandex.cloud.datasphere.v2.jobs.JobProgress.create_time:type_name -> google.protobuf.Timestamp
	41, // [41:41] is the sub-list for method output_type
	41, // [41:41] is the sub-list for method input_type
	41, // [41:41] is the sub-list for extension type_name
	41, // [41:41] is the sub-list for extension extendee
	0,  // [0:41] is the sub-list for field type_name
}

func init() { file_yandex_cloud_datasphere_v2_jobs_jobs_proto_init() }
func file_yandex_cloud_datasphere_v2_jobs_jobs_proto_init() {
	if File_yandex_cloud_datasphere_v2_jobs_jobs_proto != nil {
		return
	}
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[7].OneofWrappers = []any{
		(*FileUploadError_OutputFileDesc)(nil),
		(*FileUploadError_LogFileName)(nil),
	}
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[8].OneofWrappers = []any{
		(*Environment_DockerImageResourceId)(nil),
		(*Environment_DockerImageSpec)(nil),
	}
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes[9].OneofWrappers = []any{
		(*DockerImageSpec_PasswordPlainText)(nil),
		(*DockerImageSpec_PasswordDsSecretName)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDesc), len(file_yandex_cloud_datasphere_v2_jobs_jobs_proto_rawDesc)),
			NumEnums:      4,
			NumMessages:   22,
			NumExtensions: 0,
			NumServices:   0,
		},
		GoTypes:           file_yandex_cloud_datasphere_v2_jobs_jobs_proto_goTypes,
		DependencyIndexes: file_yandex_cloud_datasphere_v2_jobs_jobs_proto_depIdxs,
		EnumInfos:         file_yandex_cloud_datasphere_v2_jobs_jobs_proto_enumTypes,
		MessageInfos:      file_yandex_cloud_datasphere_v2_jobs_jobs_proto_msgTypes,
	}.Build()
	File_yandex_cloud_datasphere_v2_jobs_jobs_proto = out.File
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_goTypes = nil
	file_yandex_cloud_datasphere_v2_jobs_jobs_proto_depIdxs = nil
}
