@@ -1120,27 +1120,27 @@ func (r *BentoRequestReconciler) generateImageBuilderPod(ctx context.Context, op
11201120 if bentoDownloadURL == "" {
11211121 yataiClient := * yataiClient_
11221122 yataiConf := * yataiConf_
1123-
1123+
11241124 r .Recorder .Eventf (opt .BentoRequest , corev1 .EventTypeNormal , "GenerateImageBuilderPod" , "Getting bento %s from yatai service" , opt .BentoRequest .Spec .BentoTag )
11251125 bento , err = yataiClient .GetBento (ctx , bentoRepositoryName , bentoVersion )
11261126 if err != nil {
11271127 err = errors .Wrap (err , "get bento" )
11281128 return
11291129 }
11301130 r .Recorder .Eventf (opt .BentoRequest , corev1 .EventTypeNormal , "GenerateImageBuilderPod" , "Got bento %s from yatai service" , opt .BentoRequest .Spec .BentoTag )
1131-
1131+
11321132 if bento .UploadStatus != modelschemas .BentoUploadStatusSuccess {
11331133 err = errors .Errorf ("bento %s is not uploaded yet, upload status is %s" , opt .BentoRequest .Spec .BentoTag , bento .UploadStatus )
11341134 return
11351135 }
1136-
1136+
11371137 for _ , model := range bento .Models {
11381138 if model .UploadStatus != modelschemas .ModelUploadStatusSuccess {
11391139 err = errors .Errorf ("model %s:%s is not uploaded yet, upload status is %s" , model .Name , model .Version , model .UploadStatus )
11401140 return
11411141 }
11421142 }
1143-
1143+
11441144 if bento .TransmissionStrategy != nil && * bento .TransmissionStrategy == modelschemas .TransmissionStrategyPresignedURL {
11451145 var bento_ * schemasv1.BentoSchema
11461146 r .Recorder .Eventf (opt .BentoRequest , corev1 .EventTypeNormal , "GenerateImageBuilderPod" , "Getting presigned url for bento %s from yatai service" , opt .BentoRequest .Spec .BentoTag )
0 commit comments