Skip to content

Commit 47aaa6b

Browse files
authored
Fix unpack job cache issue (operator-framework#3204)
In the same vein as operator-framework#3202, use update if the unpack job already exists but isn't cached Signed-off-by: kevinrizza <[email protected]>
1 parent a7b6658 commit 47aaa6b

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

pkg/controller/bundle/bundle_unpacker.go

+6
Original file line numberDiff line numberDiff line change
@@ -671,6 +671,9 @@ func (c *ConfigMapUnpacker) ensureJob(cmRef *corev1.ObjectReference, bundlePath
671671
}
672672
if len(jobs) == 0 {
673673
job, err = c.client.BatchV1().Jobs(fresh.GetNamespace()).Create(context.TODO(), fresh, metav1.CreateOptions{})
674+
if apierrors.IsAlreadyExists(err) {
675+
job, err = c.client.BatchV1().Jobs(fresh.GetNamespace()).Update(context.TODO(), fresh, metav1.UpdateOptions{})
676+
}
674677
return
675678
}
676679

@@ -685,6 +688,9 @@ func (c *ConfigMapUnpacker) ensureJob(cmRef *corev1.ObjectReference, bundlePath
685688
if time.Now().After(cond.LastTransitionTime.Time.Add(unpackRetryInterval)) {
686689
fresh.SetName(names.SimpleNameGenerator.GenerateName(fresh.GetName()))
687690
job, err = c.client.BatchV1().Jobs(fresh.GetNamespace()).Create(context.TODO(), fresh, metav1.CreateOptions{})
691+
if apierrors.IsAlreadyExists(err) {
692+
job, err = c.client.BatchV1().Jobs(fresh.GetNamespace()).Update(context.TODO(), fresh, metav1.UpdateOptions{})
693+
}
688694
}
689695
}
690696

0 commit comments

Comments
 (0)