Documentation ¶
Index ¶
- Constants
- func InvalidFlowTaskError() error
- func InvalidFlowTaskStatus(status tsk.TaskStatus) error
- type WorkHorse
- func (w *WorkHorse) DoWork() error
- func (w *WorkHorse) Init() error
- func (w *WorkHorse) InitEnvironment() error
- func (w *WorkHorse) MountVolumes() error
- func (w *WorkHorse) PushTaskStatus(status tsk.TaskStatus) error
- func (w *WorkHorse) PushTaskStatusWithMessage(status tsk.TaskStatus, msg string) error
- func (w *WorkHorse) Shutdown() error
Constants ¶
View Source
const ( FileOpsConcurrency int = 5 DefaultOutPath = "/out" DefaultModelPath = "/saved_models" DefaultSrcPath = "/src" DefaultWorkSpacePerm = 0755 DefaultModelPerm = 0755 DefaultOutPerm = 0755 IgnoreEmptyTask bool = true IgnoreMountError bool = true DefaultWorkspaceDir = "workspace" CondaSpecName = "environment.yml" DefaultCondaEnv = "python" PipReqFileName = "requirements.txt" )
Variables ¶
This section is empty.
Functions ¶
func InvalidFlowTaskError ¶
func InvalidFlowTaskError() error
func InvalidFlowTaskStatus ¶
func InvalidFlowTaskStatus(status tsk.TaskStatus) error
Types ¶
type WorkHorse ¶
type WorkHorse struct { Id string // contains filtered or unexported fields }
func NewWorkHorse ¶
func (*WorkHorse) InitEnvironment ¶
func (*WorkHorse) MountVolumes ¶
func (*WorkHorse) PushTaskStatus ¶
func (w *WorkHorse) PushTaskStatus(status tsk.TaskStatus) error
func (*WorkHorse) PushTaskStatusWithMessage ¶
func (w *WorkHorse) PushTaskStatusWithMessage(status tsk.TaskStatus, msg string) error
Click to show internal directories.
Click to hide internal directories.