diff --git a/pkg/scheduler/internal/queue/scheduling_queue_test.go b/pkg/scheduler/internal/queue/scheduling_queue_test.go index 1add2f561eb..168e04df83e 100644 --- a/pkg/scheduler/internal/queue/scheduling_queue_test.go +++ b/pkg/scheduler/internal/queue/scheduling_queue_test.go @@ -1521,7 +1521,12 @@ func TestPodTimestamp(t *testing.T) { op(queue, test.operands[i]) } - for i := 0; i < len(test.expected); i++ { + expectedLen := len(test.expected) + if queue.activeQ.Len() != expectedLen { + t.Fatalf("Expected %v items to be in activeQ, but got: %v", expectedLen, queue.activeQ.Len()) + } + + for i := 0; i < expectedLen; i++ { if pInfo, err := queue.activeQ.Pop(); err != nil { t.Errorf("Error while popping the head of the queue: %v", err) } else {