Skip to content

Commit 7ec4770

Browse files
authored
Revert "Fix unpack job cache issue (#3204)" (#3211)
This reverts commit 47aaa6b.
1 parent 32d8782 commit 7ec4770

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

pkg/controller/bundle/bundle_unpacker.go

-6
Original file line numberDiff line numberDiff line change
@@ -671,9 +671,6 @@ 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-
}
677674
return
678675
}
679676

@@ -688,9 +685,6 @@ func (c *ConfigMapUnpacker) ensureJob(cmRef *corev1.ObjectReference, bundlePath
688685
if time.Now().After(cond.LastTransitionTime.Time.Add(unpackRetryInterval)) {
689686
fresh.SetName(names.SimpleNameGenerator.GenerateName(fresh.GetName()))
690687
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-
}
694688
}
695689
}
696690

0 commit comments

Comments
 (0)