in kubernetes/controllers/job.go [57:75]
func (r *ElasticJobReconciler) GetJobFromAPIClient(namespace, name string) (metav1.Object, error) {
job := &v1alpha1.ElasticJob{}
log := logger.LoggerForJob(job)
clientReader, err := getClientReaderFromClient(r.Client)
if err != nil {
return nil, err
}
err = clientReader.Get(context.Background(), types.NamespacedName{Namespace: namespace, Name: name}, job)
if err != nil {
if errors.IsNotFound(err) {
log.Errorf("ElasticJob %s/%s not found. %v", namespace, name, err)
} else {
log.Errorf("failed to get job %s/%s from api-server. %v", namespace, name, err)
}
return nil, err
}
return job, nil
}