kubeflow

Documentation

Index

• Variables
• func CreatePodSetAssigment(createdWorkload *kueue.Workload, podSetsResource []PodSetsResource) []kueue.PodSetAssignment
• func ShouldReconcileJob(ctx context.Context, k8sClient client.Client, ...)
• type PodSetsResource
• type PodsReadyTestSpec

Variables

var ReplicaTypeWorker = kftraining.ReplicaType("Worker")

Functions

func CreatePodSetAssigment

func CreatePodSetAssigment(createdWorkload *kueue.Workload, podSetsResource []PodSetsResource) []kueue.PodSetAssignment

func ShouldReconcileJob

func ShouldReconcileJob(ctx context.Context, k8sClient client.Client, job, createdJob kubeflowjob.KubeflowJob, ns *corev1.Namespace, wlLookupKey types.NamespacedName, podSetsResources []PodSetsResource)

Types

type PodSetsResource

type PodSetsResource struct {
	NodeName    kftraining.ReplicaType
	ResourceCPU kueue.ResourceFlavorReference
}

type PodsReadyTestSpec

type PodsReadyTestSpec struct {
	BeforeJobStatus *kftraining.JobStatus
	BeforeCondition *metav1.Condition
	JobStatus       kftraining.JobStatus
	Suspended       bool
	WantCondition   *metav1.Condition
}