mirror of
https://github.com/hibiken/asynq.git
synced 2025-04-22 16:50:18 +08:00
Fix build
This commit is contained in:
parent
7d516e37e6
commit
4c2c98db78
@ -259,8 +259,8 @@ func BenchmarkCheckAndEnqueue(b *testing.B) {
|
|||||||
asynqtest.SeedScheduledQueue(b, r.client, zs, base.DefaultQueueName)
|
asynqtest.SeedScheduledQueue(b, r.client, zs, base.DefaultQueueName)
|
||||||
b.StartTimer()
|
b.StartTimer()
|
||||||
|
|
||||||
if err := r.CheckAndEnqueue(base.DefaultQueueName); err != nil {
|
if err := r.ForwardIfReady(base.DefaultQueueName); err != nil {
|
||||||
b.Fatalf("CheckAndEnqueue failed: %v", err)
|
b.Fatalf("ForwardIfReady failed: %v", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user