diff --git a/gateway/qualification_harness_test.go b/gateway/qualification_harness_test.go
index ac11a2d..72ec722 100644
--- a/gateway/qualification_harness_test.go
+++ b/gateway/qualification_harness_test.go
@@ -835,7 +835,8 @@ func (p *qualificationPath) traverse(t *testing.T, payload []byte) (qualificatio
 	afterMetrics := p.server.Metrics()
 	deadline := time.Now().Add(2 * time.Second)
 	for (afterMetrics.ProcessingSamples < beforeMetrics.ProcessingSamples+1 ||
-		afterMetrics.MediaPackets <= beforeMetrics.MediaPackets) && time.Now().Before(deadline) {
+		afterMetrics.MediaPackets <= beforeMetrics.MediaPackets ||
+		p.session.mediaEnqueued.Load() <= beforeEnqueued) && time.Now().Before(deadline) {
 		runtime.Gosched()
 		afterMetrics = p.server.Metrics()
 	}