taskv1

package
v0.0.0-...-3511abf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 2, 2023 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		3: "STATE_PULLING",
		4: "STATE_STARTING",
		5: "STATE_RUNNING",
		6: "STATE_TERMINATED",
		7: "STATE_TERMINATING",
		9: "STATE_WAITING",
		8: "STATE_QUEUED",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_PULLING":     3,
		"STATE_STARTING":    4,
		"STATE_RUNNING":     5,
		"STATE_TERMINATED":  6,
		"STATE_TERMINATING": 7,
		"STATE_WAITING":     9,
		"STATE_QUEUED":      8,
	}
)

Enum value maps for State.

View Source
var (
	TaskType_name = map[int32]string{
		0: "TASK_TYPE_UNSPECIFIED",
		1: "TASK_TYPE_TRIAL",
		2: "TASK_TYPE_NOTEBOOK",
		3: "TASK_TYPE_SHELL",
		4: "TASK_TYPE_COMMAND",
		5: "TASK_TYPE_TENSORBOARD",
		6: "TASK_TYPE_CHECKPOINT_GC",
	}
	TaskType_value = map[string]int32{
		"TASK_TYPE_UNSPECIFIED":   0,
		"TASK_TYPE_TRIAL":         1,
		"TASK_TYPE_NOTEBOOK":      2,
		"TASK_TYPE_SHELL":         3,
		"TASK_TYPE_COMMAND":       4,
		"TASK_TYPE_TENSORBOARD":   5,
		"TASK_TYPE_CHECKPOINT_GC": 6,
	}
)

Enum value maps for TaskType.

View Source
var (
	FailureType_name = map[int32]string{
		0: "FAILURE_TYPE_UNSPECIFIED",
		1: "FAILURE_TYPE_RESOURCES_FAILED",
		2: "FAILURE_TYPE_RESOURCES_ABORTED",
		3: "FAILURE_TYPE_RESOURCES_MISSING",
		4: "FAILURE_TYPE_TASK_ABORTED",
		5: "FAILURE_TYPE_TASK_ERROR",
		6: "FAILURE_TYPE_AGENT_FAILED",
		7: "FAILURE_TYPE_AGENT_ERROR",
		8: "FAILURE_TYPE_RESTORE_ERROR",
		9: "FAILURE_TYPE_UNKNOWN_ERROR",
	}
	FailureType_value = map[string]int32{
		"FAILURE_TYPE_UNSPECIFIED":       0,
		"FAILURE_TYPE_RESOURCES_FAILED":  1,
		"FAILURE_TYPE_RESOURCES_ABORTED": 2,
		"FAILURE_TYPE_RESOURCES_MISSING": 3,
		"FAILURE_TYPE_TASK_ABORTED":      4,
		"FAILURE_TYPE_TASK_ERROR":        5,
		"FAILURE_TYPE_AGENT_FAILED":      6,
		"FAILURE_TYPE_AGENT_ERROR":       7,
		"FAILURE_TYPE_RESTORE_ERROR":     8,
		"FAILURE_TYPE_UNKNOWN_ERROR":     9,
	}
)

Enum value maps for FailureType.

View Source
var File_determined_task_v1_task_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Address

type Address struct {

	// ContainerIP is the IP address from inside the container.
	ContainerIp string `protobuf:"bytes,1,opt,name=container_ip,json=containerIp,proto3" json:"container_ip,omitempty"`
	// ContainerPort is the port from inside the container.
	ContainerPort int32 `protobuf:"varint,2,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	// HostIP is the IP address from outside the container. This can be
	// different than the ContainerIP because of network forwarding on the host
	// machine.
	HostIp string `protobuf:"bytes,3,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
	// HostPort is the IP port from outside the container. This can be different
	// than the ContainerPort because of network forwarding on the host machine.
	HostPort int32 `protobuf:"varint,4,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`
	// contains filtered or unexported fields
}

Address represents an exposed port on a container.

func (*Address) Descriptor deprecated

func (*Address) Descriptor() ([]byte, []int)

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetContainerIp

func (x *Address) GetContainerIp() string

func (*Address) GetContainerPort

func (x *Address) GetContainerPort() int32

func (*Address) GetHostIp

func (x *Address) GetHostIp() string

func (*Address) GetHostPort

func (x *Address) GetHostPort() int32

func (*Address) ProtoMessage

func (*Address) ProtoMessage()

func (*Address) ProtoReflect

func (x *Address) ProtoReflect() protoreflect.Message

func (*Address) Reset

func (x *Address) Reset()

func (*Address) String

func (x *Address) String() string

type Allocation

type Allocation struct {

	// Unique ID of task associated with the allocation.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The current state of the allocation.
	State State `protobuf:"varint,2,opt,name=state,proto3,enum=determined.task.v1.State" json:"state,omitempty"`
	// Whether the allocation is ready to access.
	IsReady *bool `protobuf:"varint,3,opt,name=is_ready,json=isReady,proto3,oneof" json:"is_ready,omitempty"`
	// Start timestamp.
	StartTime *string `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	// End timestamp if completed.
	EndTime *string `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// Unique ID of the allocation.
	AllocationId string `protobuf:"bytes,6,opt,name=allocation_id,json=allocationId,proto3" json:"allocation_id,omitempty"`
	// The number of slots associated with the allocation.
	Slots int32 `protobuf:"varint,7,opt,name=slots,proto3" json:"slots,omitempty"`
	// The exit reason for the allocation.
	ExitReason *string `protobuf:"bytes,8,opt,name=exit_reason,json=exitReason,proto3,oneof" json:"exit_reason,omitempty"`
	// The status code the allocation exits with.
	StatusCode *int32 `protobuf:"varint,9,opt,name=status_code,json=statusCode,proto3,oneof" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

Allocation tracks a specific instance of a Task.

func (*Allocation) Descriptor deprecated

func (*Allocation) Descriptor() ([]byte, []int)

Deprecated: Use Allocation.ProtoReflect.Descriptor instead.

func (*Allocation) GetAllocationId

func (x *Allocation) GetAllocationId() string

func (*Allocation) GetEndTime

func (x *Allocation) GetEndTime() string

func (*Allocation) GetExitReason

func (x *Allocation) GetExitReason() string

func (*Allocation) GetIsReady

func (x *Allocation) GetIsReady() bool

func (*Allocation) GetSlots

func (x *Allocation) GetSlots() int32

func (*Allocation) GetStartTime

func (x *Allocation) GetStartTime() string

func (*Allocation) GetState

func (x *Allocation) GetState() State

func (*Allocation) GetStatusCode

func (x *Allocation) GetStatusCode() int32

func (*Allocation) GetTaskId

func (x *Allocation) GetTaskId() string

func (*Allocation) ProtoMessage

func (*Allocation) ProtoMessage()

func (*Allocation) ProtoReflect

func (x *Allocation) ProtoReflect() protoreflect.Message

func (*Allocation) Reset

func (x *Allocation) Reset()

func (*Allocation) String

func (x *Allocation) String() string

type AllocationSummary

type AllocationSummary struct {

	// TaskID is the unique ID of a task among all tasks.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// AllocationID is the ID of an allocation of a task. It is usually of the
	// form TaskID.allocation_number, maybe with some other metadata if different
	// types of allocations run.
	AllocationId string `protobuf:"bytes,2,opt,name=allocation_id,json=allocationId,proto3" json:"allocation_id,omitempty"`
	// The name of the task.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// The registered time of the task.
	RegisteredTime *timestamp.Timestamp `protobuf:"bytes,4,opt,name=registered_time,json=registeredTime,proto3" json:"registered_time,omitempty"`
	// The name of the resource pool.
	ResourcePool string `protobuf:"bytes,5,opt,name=resource_pool,json=resourcePool,proto3" json:"resource_pool,omitempty"`
	// The number of slots that are needed.
	SlotsNeeded int32 `protobuf:"varint,6,opt,name=slots_needed,json=slotsNeeded,proto3" json:"slots_needed,omitempty"`
	// ResourcesSummary provides a summary of the resources comprising what we
	// know at the time the allocation is granted.
	Resources []*ResourcesSummary `protobuf:"bytes,7,rep,name=resources,proto3" json:"resources,omitempty"`
	// The type of the scheduler. Either 'FAIR_SHARE', 'PRIORITY', or
	// 'ROUND_ROBIN'.
	SchedulerType string `protobuf:"bytes,8,opt,name=scheduler_type,json=schedulerType,proto3" json:"scheduler_type,omitempty"`
	// THe priority of the task.
	Priority *int32 `protobuf:"varint,9,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
	// ProxyPortConfig configures a proxy the allocation should start.
	ProxyPorts []*ProxyPortConfig `protobuf:"bytes,10,rep,name=proxy_ports,json=proxyPorts,proto3" json:"proxy_ports,omitempty"`
	// contains filtered or unexported fields
}

AllocationSummary contains information about a task for external display.

func (*AllocationSummary) Descriptor deprecated

func (*AllocationSummary) Descriptor() ([]byte, []int)

Deprecated: Use AllocationSummary.ProtoReflect.Descriptor instead.

func (*AllocationSummary) GetAllocationId

func (x *AllocationSummary) GetAllocationId() string

func (*AllocationSummary) GetName

func (x *AllocationSummary) GetName() string

func (*AllocationSummary) GetPriority

func (x *AllocationSummary) GetPriority() int32

func (*AllocationSummary) GetProxyPorts

func (x *AllocationSummary) GetProxyPorts() []*ProxyPortConfig

func (*AllocationSummary) GetRegisteredTime

func (x *AllocationSummary) GetRegisteredTime() *timestamp.Timestamp

func (*AllocationSummary) GetResourcePool

func (x *AllocationSummary) GetResourcePool() string

func (*AllocationSummary) GetResources

func (x *AllocationSummary) GetResources() []*ResourcesSummary

func (*AllocationSummary) GetSchedulerType

func (x *AllocationSummary) GetSchedulerType() string

func (*AllocationSummary) GetSlotsNeeded

func (x *AllocationSummary) GetSlotsNeeded() int32

func (*AllocationSummary) GetTaskId

func (x *AllocationSummary) GetTaskId() string

func (*AllocationSummary) ProtoMessage

func (*AllocationSummary) ProtoMessage()

func (*AllocationSummary) ProtoReflect

func (x *AllocationSummary) ProtoReflect() protoreflect.Message

func (*AllocationSummary) Reset

func (x *AllocationSummary) Reset()

func (*AllocationSummary) String

func (x *AllocationSummary) String() string

type FailureType

type FailureType int32

The failure type of a resource.

const (
	// UNSPECIFIED denotes an error that is not defined below.
	FailureType_FAILURE_TYPE_UNSPECIFIED FailureType = 0
	// ResourcesFailed denotes that the container ran but failed with a non-zero
	// exit code.
	FailureType_FAILURE_TYPE_RESOURCES_FAILED FailureType = 1
	// ResourcesAborted denotes the container was canceled before it was started.
	FailureType_FAILURE_TYPE_RESOURCES_ABORTED FailureType = 2
	// ResourcesMissing denotes the resources were missing when the master asked
	// about it.
	FailureType_FAILURE_TYPE_RESOURCES_MISSING FailureType = 3
	// TaskAborted denotes that the task was canceled before it was started.
	FailureType_FAILURE_TYPE_TASK_ABORTED FailureType = 4
	// TaskError denotes that the task failed without an associated exit code.
	FailureType_FAILURE_TYPE_TASK_ERROR FailureType = 5
	// AgentFailed denotes that the agent failed while the container was running.
	FailureType_FAILURE_TYPE_AGENT_FAILED FailureType = 6
	// AgentError denotes that the agent failed to launch the container.
	FailureType_FAILURE_TYPE_AGENT_ERROR FailureType = 7
	// RestoreError denotes a failure to restore a running allocation on master
	// blip.
	FailureType_FAILURE_TYPE_RESTORE_ERROR FailureType = 8
	// UnknownError denotes an internal error that did not map to a know failure
	// type.
	FailureType_FAILURE_TYPE_UNKNOWN_ERROR FailureType = 9
)

func (FailureType) Descriptor

func (FailureType) Enum

func (x FailureType) Enum() *FailureType

func (FailureType) EnumDescriptor deprecated

func (FailureType) EnumDescriptor() ([]byte, []int)

Deprecated: Use FailureType.Descriptor instead.

func (FailureType) Number

func (x FailureType) Number() protoreflect.EnumNumber

func (FailureType) String

func (x FailureType) String() string

func (FailureType) Type

type ProxyPortConfig

type ProxyPortConfig struct {

	// The service ID of the proxy port config.
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// The port of the proxy port config.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// True if proxy uses TCP.
	ProxyTcp bool `protobuf:"varint,3,opt,name=proxy_tcp,json=proxyTcp,proto3" json:"proxy_tcp,omitempty"`
	// True if the proxy is unauthenticated.
	Unauthenticated bool `protobuf:"varint,4,opt,name=unauthenticated,proto3" json:"unauthenticated,omitempty"`
	// contains filtered or unexported fields
}

ProxyPortConfig configures a proxy the allocation should start.

func (*ProxyPortConfig) Descriptor deprecated

func (*ProxyPortConfig) Descriptor() ([]byte, []int)

Deprecated: Use ProxyPortConfig.ProtoReflect.Descriptor instead.

func (*ProxyPortConfig) GetPort

func (x *ProxyPortConfig) GetPort() int32

func (*ProxyPortConfig) GetProxyTcp

func (x *ProxyPortConfig) GetProxyTcp() bool

func (*ProxyPortConfig) GetServiceId

func (x *ProxyPortConfig) GetServiceId() string

func (*ProxyPortConfig) GetUnauthenticated

func (x *ProxyPortConfig) GetUnauthenticated() bool

func (*ProxyPortConfig) ProtoMessage

func (*ProxyPortConfig) ProtoMessage()

func (*ProxyPortConfig) ProtoReflect

func (x *ProxyPortConfig) ProtoReflect() protoreflect.Message

func (*ProxyPortConfig) Reset

func (x *ProxyPortConfig) Reset()

func (*ProxyPortConfig) String

func (x *ProxyPortConfig) String() string

type ResourcesFailure

type ResourcesFailure struct {

	// FailureType denotes the type of failure that resulted in the container
	// stopping.
	FailureType FailureType `` /* 131-byte string literal not displayed */
	// The error message of the failure.
	ErrMsg string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// The exit code of the failure.
	ExitCode *int32 `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3,oneof" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

ResourcesFailure contains information about restored resources' failure.

func (*ResourcesFailure) Descriptor deprecated

func (*ResourcesFailure) Descriptor() ([]byte, []int)

Deprecated: Use ResourcesFailure.ProtoReflect.Descriptor instead.

func (*ResourcesFailure) GetErrMsg

func (x *ResourcesFailure) GetErrMsg() string

func (*ResourcesFailure) GetExitCode

func (x *ResourcesFailure) GetExitCode() int32

func (*ResourcesFailure) GetFailureType

func (x *ResourcesFailure) GetFailureType() FailureType

func (*ResourcesFailure) ProtoMessage

func (*ResourcesFailure) ProtoMessage()

func (*ResourcesFailure) ProtoReflect

func (x *ResourcesFailure) ProtoReflect() protoreflect.Message

func (*ResourcesFailure) Reset

func (x *ResourcesFailure) Reset()

func (*ResourcesFailure) String

func (x *ResourcesFailure) String() string

type ResourcesStarted

type ResourcesStarted struct {

	// Addresses represents the exposed ports on a container.
	Addresses []*Address `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// NativeResourcesID is the native Docker hex container ID of the Determined
	// container.
	NativeResourcesId string `protobuf:"bytes,2,opt,name=native_resources_id,json=nativeResourcesId,proto3" json:"native_resources_id,omitempty"`
	// contains filtered or unexported fields
}

ResourcesStarted contains the information needed by tasks from container started.

func (*ResourcesStarted) Descriptor deprecated

func (*ResourcesStarted) Descriptor() ([]byte, []int)

Deprecated: Use ResourcesStarted.ProtoReflect.Descriptor instead.

func (*ResourcesStarted) GetAddresses

func (x *ResourcesStarted) GetAddresses() []*Address

func (*ResourcesStarted) GetNativeResourcesId

func (x *ResourcesStarted) GetNativeResourcesId() string

func (*ResourcesStarted) ProtoMessage

func (*ResourcesStarted) ProtoMessage()

func (*ResourcesStarted) ProtoReflect

func (x *ResourcesStarted) ProtoReflect() protoreflect.Message

func (*ResourcesStarted) Reset

func (x *ResourcesStarted) Reset()

func (*ResourcesStarted) String

func (x *ResourcesStarted) String() string

type ResourcesStopped

type ResourcesStopped struct {

	// ResourcesFailure contains information about restored resources' failure.
	Failure *ResourcesFailure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

ResourcesStopped contains the information needed by tasks from container stopped.

func (*ResourcesStopped) Descriptor deprecated

func (*ResourcesStopped) Descriptor() ([]byte, []int)

Deprecated: Use ResourcesStopped.ProtoReflect.Descriptor instead.

func (*ResourcesStopped) GetFailure

func (x *ResourcesStopped) GetFailure() *ResourcesFailure

func (*ResourcesStopped) ProtoMessage

func (*ResourcesStopped) ProtoMessage()

func (*ResourcesStopped) ProtoReflect

func (x *ResourcesStopped) ProtoReflect() protoreflect.Message

func (*ResourcesStopped) Reset

func (x *ResourcesStopped) Reset()

func (*ResourcesStopped) String

func (x *ResourcesStopped) String() string

type ResourcesSummary

type ResourcesSummary struct {

	// ResourcesID is the ID of some set of resources.
	ResourcesId string `protobuf:"bytes,1,opt,name=resources_id,json=resourcesId,proto3" json:"resources_id,omitempty"`
	// ResourcesType is the type of some set of resources. This should be purely
	// informational.
	ResourcesType string `protobuf:"bytes,2,opt,name=resources_type,json=resourcesType,proto3" json:"resources_type,omitempty"`
	// AllocationID is the ID of an allocation of a task.
	AllocationId string `protobuf:"bytes,3,opt,name=allocation_id,json=allocationId,proto3" json:"allocation_id,omitempty"`
	// ID, an identifier for an agent, maps to the associated devices.
	AgentDevices map[string]*ResourcesSummary_Devices `` /* 185-byte string literal not displayed */
	// Available if the RM can give information on the container level.
	ContainerId *string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3,oneof" json:"container_id,omitempty"`
	// Available if the RM knows the resource is already started / exited.
	Started *ResourcesStarted `protobuf:"bytes,6,opt,name=started,proto3,oneof" json:"started,omitempty"`
	// ResourcesStopped contains the information needed by tasks from container
	// stopped.
	Exited *ResourcesStopped `protobuf:"bytes,7,opt,name=exited,proto3,oneof" json:"exited,omitempty"`
	// contains filtered or unexported fields
}

ResourcesSummary provides a summary of the resources comprising what we know at the time the allocation is granted, but for k8s it is granted before being scheduled so it isn't really much and `agent_devices` are missing for k8s.

func (*ResourcesSummary) Descriptor deprecated

func (*ResourcesSummary) Descriptor() ([]byte, []int)

Deprecated: Use ResourcesSummary.ProtoReflect.Descriptor instead.

func (*ResourcesSummary) GetAgentDevices

func (x *ResourcesSummary) GetAgentDevices() map[string]*ResourcesSummary_Devices

func (*ResourcesSummary) GetAllocationId

func (x *ResourcesSummary) GetAllocationId() string

func (*ResourcesSummary) GetContainerId

func (x *ResourcesSummary) GetContainerId() string

func (*ResourcesSummary) GetExited

func (x *ResourcesSummary) GetExited() *ResourcesStopped

func (*ResourcesSummary) GetResourcesId

func (x *ResourcesSummary) GetResourcesId() string

func (*ResourcesSummary) GetResourcesType

func (x *ResourcesSummary) GetResourcesType() string

func (*ResourcesSummary) GetStarted

func (x *ResourcesSummary) GetStarted() *ResourcesStarted

func (*ResourcesSummary) ProtoMessage

func (*ResourcesSummary) ProtoMessage()

func (*ResourcesSummary) ProtoReflect

func (x *ResourcesSummary) ProtoReflect() protoreflect.Message

func (*ResourcesSummary) Reset

func (x *ResourcesSummary) Reset()

func (*ResourcesSummary) String

func (x *ResourcesSummary) String() string

type ResourcesSummary_Devices

type ResourcesSummary_Devices struct {

	// The devices on an agent.
	Devices []*devicev1.Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	// contains filtered or unexported fields
}

A wrapper message of a list of devices.

func (*ResourcesSummary_Devices) Descriptor deprecated

func (*ResourcesSummary_Devices) Descriptor() ([]byte, []int)

Deprecated: Use ResourcesSummary_Devices.ProtoReflect.Descriptor instead.

func (*ResourcesSummary_Devices) GetDevices

func (x *ResourcesSummary_Devices) GetDevices() []*devicev1.Device

func (*ResourcesSummary_Devices) ProtoMessage

func (*ResourcesSummary_Devices) ProtoMessage()

func (*ResourcesSummary_Devices) ProtoReflect

func (x *ResourcesSummary_Devices) ProtoReflect() protoreflect.Message

func (*ResourcesSummary_Devices) Reset

func (x *ResourcesSummary_Devices) Reset()

func (*ResourcesSummary_Devices) String

func (x *ResourcesSummary_Devices) String() string

type State

type State int32

The current state of the task.

const (
	// The task state is unknown.
	State_STATE_UNSPECIFIED State = 0
	// The task's base image is being pulled from the Docker registry.
	State_STATE_PULLING State = 3
	// The image has been pulled and the task is being started, but the task is
	// not ready yet.
	State_STATE_STARTING State = 4
	// The service in the task is running.
	State_STATE_RUNNING State = 5
	// The task has exited or has been aborted.
	State_STATE_TERMINATED State = 6
	// The task has begun to exit.
	State_STATE_TERMINATING State = 7
	// The task is waiting on something to complete.
	State_STATE_WAITING State = 9
	// Additional state to cover queueing operations.
	State_STATE_QUEUED State = 8
)

func (State) Descriptor

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum

func (x State) Enum() *State

func (State) EnumDescriptor deprecated

func (State) EnumDescriptor() ([]byte, []int)

Deprecated: Use State.Descriptor instead.

func (State) Number

func (x State) Number() protoreflect.EnumNumber

func (State) String

func (x State) String() string

func (State) Type

func (State) Type() protoreflect.EnumType

type Task

type Task struct {

	// Unique ID of task.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Type of Task.
	TaskType TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=determined.task.v1.TaskType" json:"task_type,omitempty"`
	// List of Allocations.
	Allocations []*Allocation `protobuf:"bytes,4,rep,name=allocations,proto3" json:"allocations,omitempty"`
	// Start timestamp.
	StartTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// End timestamp if completed.
	EndTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

Task is the model for a task in the database.

func (*Task) Descriptor deprecated

func (*Task) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetAllocations

func (x *Task) GetAllocations() []*Allocation

func (*Task) GetEndTime

func (x *Task) GetEndTime() *timestamp.Timestamp

func (*Task) GetStartTime

func (x *Task) GetStartTime() *timestamp.Timestamp

func (*Task) GetTaskId

func (x *Task) GetTaskId() string

func (*Task) GetTaskType

func (x *Task) GetTaskType() TaskType

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

type TaskLog

type TaskLog struct {

	// The ID of the log.
	Id *int32 `protobuf:"varint,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
	// The ID of the task.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The ID of the allocation.
	AllocationId *string `protobuf:"bytes,3,opt,name=allocation_id,json=allocationId,proto3,oneof" json:"allocation_id,omitempty"`
	// The agent the logs came from.
	AgentId *string `protobuf:"bytes,4,opt,name=agent_id,json=agentId,proto3,oneof" json:"agent_id,omitempty"`
	// The ID of the container or, in the case of k8s, the pod name.
	ContainerId *string `protobuf:"bytes,5,opt,name=container_id,json=containerId,proto3,oneof" json:"container_id,omitempty"`
	// The rank ID.
	RankId *int32 `protobuf:"varint,6,opt,name=rank_id,json=rankId,proto3,oneof" json:"rank_id,omitempty"`
	// The timestamp of the log.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,7,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
	// The level of this log.
	Level *logv1.LogLevel `protobuf:"varint,8,opt,name=level,proto3,enum=determined.log.v1.LogLevel,oneof" json:"level,omitempty"`
	// The text of the log entry.
	Log string `protobuf:"bytes,9,opt,name=log,proto3" json:"log,omitempty"`
	// The source of the log entry.
	Source *string `protobuf:"bytes,10,opt,name=source,proto3,oneof" json:"source,omitempty"`
	// The output stream (e.g. stdout, stderr).
	Stdtype *string `protobuf:"bytes,11,opt,name=stdtype,proto3,oneof" json:"stdtype,omitempty"`
	// contains filtered or unexported fields
}

TaskLog is the model for a task log in the database

func (*TaskLog) Descriptor deprecated

func (*TaskLog) Descriptor() ([]byte, []int)

Deprecated: Use TaskLog.ProtoReflect.Descriptor instead.

func (*TaskLog) GetAgentId

func (x *TaskLog) GetAgentId() string

func (*TaskLog) GetAllocationId

func (x *TaskLog) GetAllocationId() string

func (*TaskLog) GetContainerId

func (x *TaskLog) GetContainerId() string

func (*TaskLog) GetId

func (x *TaskLog) GetId() int32

func (*TaskLog) GetLevel

func (x *TaskLog) GetLevel() logv1.LogLevel

func (*TaskLog) GetLog

func (x *TaskLog) GetLog() string

func (*TaskLog) GetRankId

func (x *TaskLog) GetRankId() int32

func (*TaskLog) GetSource

func (x *TaskLog) GetSource() string

func (*TaskLog) GetStdtype

func (x *TaskLog) GetStdtype() string

func (*TaskLog) GetTaskId

func (x *TaskLog) GetTaskId() string

func (*TaskLog) GetTimestamp

func (x *TaskLog) GetTimestamp() *timestamp.Timestamp

func (*TaskLog) ProtoMessage

func (*TaskLog) ProtoMessage()

func (*TaskLog) ProtoReflect

func (x *TaskLog) ProtoReflect() protoreflect.Message

func (*TaskLog) Reset

func (x *TaskLog) Reset()

func (*TaskLog) String

func (x *TaskLog) String() string

type TaskType

type TaskType int32

Type of the task

const (
	// The task type is unknown
	TaskType_TASK_TYPE_UNSPECIFIED TaskType = 0
	// "TRIAL" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_TRIAL TaskType = 1
	// "NOTEBOOK" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_NOTEBOOK TaskType = 2
	// "SHELL" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_SHELL TaskType = 3
	// "COMMAND" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_COMMAND TaskType = 4
	// "TENSORBOARD" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_TENSORBOARD TaskType = 5
	// "CHECKPOINT_GC" task type for the enum public.task_type in Postgres.
	TaskType_TASK_TYPE_CHECKPOINT_GC TaskType = 6
)

func (TaskType) Descriptor

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated

func (TaskType) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String

func (x TaskType) String() string

func (TaskType) Type

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL