func newJobWithOptions()

in internal/utils/controller/appdeployment_job.go [76:99]

• 22 lines of code
• 2 McCabe index (conditional complexity)

func newJobWithOptions(options jobOptions) *batchv1.Job {
	options.jobSpec.Template.Spec.Containers[0].Env = append(options.jobSpec.Template.Spec.Containers[0].Env, corev1.EnvVar{
		Name:  OperationIDEnvKey,
		Value: options.operationID,
	})
	job := &batchv1.Job{
		ObjectMeta: metav1.ObjectMeta{
			Name:        options.name,
			Namespace:   options.namespace,
			Labels:      options.labels,
			Annotations: options.annotations,
		},
		Spec: options.jobSpec,
	}
	job.Spec.Template.Spec.RestartPolicy = corev1.RestartPolicyOnFailure
	job.Spec.BackoffLimit = &backOffLimit
	job.Spec.TTLSecondsAfterFinished = &ttlSecondsAfterFinished

	if len(options.ownerRefs) > 0 {
		job.OwnerReferences = options.ownerRefs
	}

	return job
}