Skip to content

Commit

Permalink
Merge pull request #362 from jpodivin/existence
Browse files Browse the repository at this point in the history
Removed duplicated conditional and improved logging message
  • Loading branch information
stuggi authored Oct 11, 2023
2 parents 8f26e4f + 614cd0d commit 3bdf9ff
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions modules/common/job/job.go
Original file line number Diff line number Diff line change
Expand Up @@ -145,12 +145,13 @@ func (j *Job) DoJob(
// Check if this job already exists
//
j.actualJob, err = GetJobWithName(ctx, h, j.expectedJob.Name, j.expectedJob.Namespace)
if err != nil && !k8s_errors.IsNotFound(err) {
return ctrl.Result{}, err
}

exists := !k8s_errors.IsNotFound(err)

if err != nil && exists {
return ctrl.Result{}, fmt.Errorf("error getting existing job %s : %w", j.jobType, err)
}

// If the hash of the job not changed then we don't need to create or wait
// for any jobs
if !j.changed {
Expand Down Expand Up @@ -290,10 +291,7 @@ func GetJobWithName(
job := &batchv1.Job{}
err := h.GetClient().Get(ctx, types.NamespacedName{Name: name, Namespace: namespace}, job)
if err != nil {
if k8s_errors.IsNotFound(err) {
return job, err
}
h.GetLogger().Info("GetJobWithName err")
h.GetLogger().Info("GetJobWithName %s err: %w", name, err)
return job, err
}

Expand Down

0 comments on commit 3bdf9ff

Please sign in to comment.