diff --git a/internal/otelarrow/admission2/boundedqueue_test.go b/internal/otelarrow/admission2/boundedqueue_test.go index a177267543b25..bb999e91e576e 100644 --- a/internal/otelarrow/admission2/boundedqueue_test.go +++ b/internal/otelarrow/admission2/boundedqueue_test.go @@ -67,12 +67,10 @@ func (bq *bqTest) startWaiter(ctx context.Context, size uint64, relp *ReleaseFun } func (bq *bqTest) waitForPending(admitted, waiting uint64) { - // TODO: Remove time.Sleep below, see https://github.com/open-telemetry/opentelemetry-collector-contrib/issues/42514 - time.Sleep(20 * time.Millisecond) - require.Eventually(bq.t, func() bool { + require.EventuallyWithT(bq.t, func(c *assert.CollectT) { bq.lock.Lock() defer bq.lock.Unlock() - return bq.currentAdmitted == admitted && bq.currentWaiting == waiting + assert.True(c, bq.currentAdmitted == admitted && bq.currentWaiting == waiting) }, 10*time.Second, 20*time.Millisecond) }