@@ -26,7 +26,7 @@ import (
2626 "os"
2727 "reflect"
2828
29- batchv1 "k8s.io/api/batch/v1"
29+ batch "k8s.io/api/batch/v1"
3030 core "k8s.io/api/core/v1"
3131 meta "k8s.io/apimachinery/pkg/apis/meta/v1"
3232 "k8s.io/client-go/kubernetes"
@@ -92,20 +92,20 @@ func (h *handler) Handle(item operation.Item) error {
9292 return nil
9393}
9494
95- func (h * handler ) createFailedJobStatusWithEvent (msg string , job * appsApi.ArangoJob ) batchv1 .JobStatus {
95+ func (h * handler ) createFailedJobStatusWithEvent (msg string , job * appsApi.ArangoJob ) batch .JobStatus {
9696 h .eventRecorder .Warning (job , jobError , msg )
97- return batchv1 .JobStatus {
98- Conditions : []batchv1 .JobCondition {
97+ return batch .JobStatus {
98+ Conditions : []batch .JobCondition {
9999 {
100- Type : batchv1 .JobFailed ,
100+ Type : batch .JobFailed ,
101101 Status : core .ConditionUnknown ,
102102 Message : msg ,
103103 },
104104 },
105105 }
106106}
107107
108- func (h * handler ) processArangoJob (job * appsApi.ArangoJob ) batchv1 .JobStatus {
108+ func (h * handler ) processArangoJob (job * appsApi.ArangoJob ) batch .JobStatus {
109109 existingJob , err := h .kubeClient .BatchV1 ().Jobs (job .Namespace ).Get (context .Background (), job .Name , meta.GetOptions {})
110110 if err != nil {
111111 if k8sutil .IsNotFound (err ) {
@@ -127,8 +127,8 @@ func (h *handler) processArangoJob(job *appsApi.ArangoJob) batchv1.JobStatus {
127127 return existingJob .Status
128128}
129129
130- func (h * handler ) prepareK8sJob (job * appsApi.ArangoJob ) (* batchv1 .Job , error ) {
131- k8sJob := batchv1 .Job {}
130+ func (h * handler ) prepareK8sJob (job * appsApi.ArangoJob ) (* batch .Job , error ) {
131+ k8sJob := batch .Job {}
132132 k8sJob .Name = job .Name
133133 k8sJob .Namespace = job .Namespace
134134 k8sJob .Spec = * job .Spec .JobTemplate
0 commit comments