diff --git a/internal/rdb/benchmark_test.go b/internal/rdb/benchmark_test.go index b9580c3..576b111 100644 --- a/internal/rdb/benchmark_test.go +++ b/internal/rdb/benchmark_test.go @@ -259,8 +259,8 @@ func BenchmarkCheckAndEnqueue(b *testing.B) { asynqtest.SeedScheduledQueue(b, r.client, zs, base.DefaultQueueName) b.StartTimer() - if err := r.CheckAndEnqueue(base.DefaultQueueName); err != nil { - b.Fatalf("CheckAndEnqueue failed: %v", err) + if err := r.ForwardIfReady(base.DefaultQueueName); err != nil { + b.Fatalf("ForwardIfReady failed: %v", err) } } }