diff --git a/test/integration/scheduler/queue_test.go b/test/integration/scheduler/queue_test.go
index 735b81d0028..fe896595b06 100644
--- a/test/integration/scheduler/queue_test.go
+++ b/test/integration/scheduler/queue_test.go
@@ -954,27 +954,30 @@ func TestCoreResourceEnqueue(t *testing.T) {
 					}
 				}
 
-				// Wait for the tt.pods to be present in the scheduling queue.
+				// Wait for the tt.pods to be present in the scheduling active queue.
 				if err := wait.PollUntilContextTimeout(ctx, time.Millisecond*200, wait.ForeverTestTimeout, false, func(ctx context.Context) (bool, error) {
-					pendingPods, _ := testCtx.Scheduler.SchedulingQueue.PendingPods()
-					return len(pendingPods) == len(tt.pods), nil
+					return len(testCtx.Scheduler.SchedulingQueue.PodsInActiveQ()) == len(tt.pods), nil
 				}); err != nil {
 					t.Fatal(err)
 				}
 
 				t.Log("Confirmed Pods in the scheduling queue, starting to schedule them")
 
-				// Pop all pods out. They should be unschedulable.
+				// Pop all pods out. They should become unschedulable.
 				for i := 0; i < len(tt.pods); i++ {
 					testCtx.Scheduler.ScheduleOne(testCtx.Ctx)
 				}
-				// Wait for the tt.pods to be still present in the scheduling queue.
+				// Wait for the tt.pods to be still present in the scheduling (unschedulable) queue.
 				if err := wait.PollUntilContextTimeout(ctx, time.Millisecond*200, wait.ForeverTestTimeout, false, func(ctx context.Context) (bool, error) {
 					pendingPods, _ := testCtx.Scheduler.SchedulingQueue.PendingPods()
 					return len(pendingPods) == len(tt.pods), nil
 				}); err != nil {
 					t.Fatal(err)
 				}
+				activePodsCount := len(testCtx.Scheduler.SchedulingQueue.PodsInActiveQ())
+				if activePodsCount > 0 {
+					t.Fatalf("Active queue was expected to be empty, but found %v Pods", activePodsCount)
+				}
 
 				t.Log("finished initial schedulings for all Pods, will trigger triggerFn")