in pkg/controller/jobs/job/job_controller.go [212:235]
func (j *Job) Finished() (metav1.Condition, bool) {
var conditionType batchv1.JobConditionType
var finished bool
for _, c := range j.Status.Conditions {
if (c.Type == batchv1.JobComplete || c.Type == batchv1.JobFailed) && c.Status == corev1.ConditionTrue {
conditionType = c.Type
finished = true
break
}
}
condition := metav1.Condition{
Type: kueue.WorkloadFinished,
Status: metav1.ConditionTrue,
Reason: "JobFinished",
Message: "Job finished successfully",
}
if conditionType == batchv1.JobFailed {
condition.Message = "Job failed"
}
return condition, finished
}