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