func()

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
}