Function verifyNoPendingRequestsLeft

pkg/scheduler/scheduler_test.go:673–679

(t *testing.T, scheduler *Scheduler)

}

func verifyNoPendingRequestsLeft(t *testing.T, scheduler *Scheduler) {
	test.Poll(t, 1*time.Second, 0, func() any {
		scheduler.pendingRequestsMu.Lock()
		defer scheduler.pendingRequestsMu.Unlock()
		return len(scheduler.pendingRequests)
	})
}

type frontendMock struct {
	mu   sync.Mutex