Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( JobGVK = k8s.PyTorchJobGVK KubePyTorchFwVersion = client.KubeFrameworkVersion(JobGVK) )
Functions ¶
func New ¶
func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface
Types ¶
type KubePyTorchJob ¶
type KubePyTorchJob struct {
kuberuntime.KubeBaseJob
}
KubePyTorchJob is a struct that runs a pytorch job
func (*KubePyTorchJob) AddEventListener ¶
func (pj *KubePyTorchJob) AddEventListener(ctx context.Context, listenerType string, jobQueue workqueue.RateLimitingInterface, listener interface{}) error
func (*KubePyTorchJob) JobStatus ¶
func (pj *KubePyTorchJob) JobStatus(obj interface{}) (api.StatusInfo, error)
JobStatus get the statusInfo of PyTorch job, including origin status, pf status and message
Source Files
Click to show internal directories.
Click to hide internal directories.