Function TestWaitForJobComplete

pkg/kube/statuswait_test.go:453–508

(t *testing.T)

}

func TestWaitForJobComplete(t *testing.T) {
	t.Parallel()
	tests := []struct {
		name          string
		objManifests  []string
		expectErrStrs []string
	}{
		{
			name:         "Job is complete",
			objManifests: []string{jobCompleteManifest},
		},
		{
			name:          "Job is not ready",
			objManifests:  []string{jobNoStatusManifest},
			expectErrStrs: []string{"resource Job/qual/test not ready. status: InProgress", "context deadline exceeded"},
		},
		{
			name:          "Job is ready but not complete",
			objManifests:  []string{jobReadyManifest},
			expectErrStrs: []string{"resource Job/default/ready-not-complete not ready. status: InProgress", "context deadline exceeded"},
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			t.Parallel()
			c := newTestClient(t)
			fakeClient := dynamicfake.NewSimpleDynamicClient(scheme.Scheme)
			fakeMapper := testutil.NewFakeRESTMapper(
				batchv1.SchemeGroupVersion.WithKind("Job"),
			)
			statusWaiter := statusWaiter{
				client:     fakeClient,
				restMapper: fakeMapper,
			}
			statusWaiter.SetLogger(slog.Default().Handler())
			objs := getRuntimeObjFromManifests(t, tt.objManifests)
			for _, obj := range objs {
				u := obj.(*unstructured.Unstructured)
				gvr := getGVR(t, fakeMapper, u)
				err := fakeClient.Tracker().Create(gvr, u, u.GetNamespace())
				assert.NoError(t, err)
			}
			resourceList := getResourceListFromRuntimeObjs(t, c, objs)
			err := statusWaiter.WaitWithJobs(resourceList, time.Second*3)
			if tt.expectErrStrs != nil {
				require.Error(t, err)
				for _, expectedErrStr := range tt.expectErrStrs {
					assert.Contains(t, err.Error(), expectedErrStr)
				}
				return
			}
			assert.NoError(t, err)
		})
	}
}

func TestWatchForReady(t *testing.T) {