Method Run

tests/integration/suite/scheduler/failurepolicy/noset/allfail.go:45–71

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

}

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

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

	_, err := client.ScheduleJob(ctx, a.scheduler.JobNowJob("test", "namespace", "appid1"))
	require.NoError(t, err)

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

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

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