github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-24 12:15:52 +00:00
Code Issues Projects Releases Wiki Activity

Fix SyncPastDeadlineJobFinished for enabling finalizer path

Browse Source
This commit is contained in:
kannon92 2023-01-08 20:35:34 +00:00
parent 3aff1f97be
commit 0362c67859
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/controller/job/job_controller_test.go
View File

@ -1866,6 +1866,9 @@ func TestSyncPastDeadlineJobFinished(t *testing.T) {
start := metav1.NewTime(fakeClock.Now().Add(-time.Second))
job.Status.StartTime = &start
}
job.Annotations = map[string]string{
batch.JobTrackingFinalizer: "",
}
_, err := clientset.BatchV1().Jobs(job.GetNamespace()).Create(ctx, job, metav1.CreateOptions{})
if err != nil {
@ -1875,6 +1878,10 @@ func TestSyncPastDeadlineJobFinished(t *testing.T) {
if err := sharedInformerFactory.Batch().V1().Jobs().Informer().GetIndexer().Add(job); err != nil {
t.Fatalf("Failed to insert job in index: %v", err)
}
// This is needed because the fake clientset doesn't report created pods
// to the informer, leading to unsatisfied expectations in syncJob that prevent the controller from setting the final condition.
podIndexer := sharedInformerFactory.Core().V1().Pods().Informer().GetIndexer()
setPodsStatuses(podIndexer, job, 0, 1, 0, 0, 0)
var j *batch.Job
err = wait.PollImmediate(200*time.Microsecond, 3*time.Second, func() (done bool, err error) {