Method Run

tests/integration/suite/scheduler/failurepolicy/drop/failed.go:46–77

(t *testing.T, ctx context.Context)

}

func (f *failed) Run(t *testing.T, ctx context.Context) {
	f.scheduler.WaitUntilRunning(t, ctx)

	client := f.scheduler.Client(t, ctx)

	job := f.scheduler.JobNowJob("test", "namespace", "appid1")
	job.Job.FailurePolicy = &corev1.JobFailurePolicy{
		Policy: &corev1.JobFailurePolicy_Drop{
			Drop: new(corev1.JobFailurePolicyDrop),
		},
	}

	_, err := client.ScheduleJob(ctx, job)
	require.NoError(t, err)

	triggered := f.scheduler.WatchJobsFailed(t, ctx, &schedulerv1.WatchJobsRequestInitial{
		AppId: "appid1", Namespace: "namespace",
	})

	select {
	case name := <-triggered:
		assert.Equal(t, "test", name)
	case <-time.After(time.Second * 5):
		require.Fail(t, "timed out waiting for job")
	}

	select {
	case <-triggered:
		assert.Fail(t, "unexpected trigger")
	case <-time.After(time.Second * 2):
	}
}