go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-26 07:42:17 +08:00
Code Issues Projects Releases Wiki Activity

Fix flaky test

Browse Source
This commit is contained in:
Ken Hibino 2020-07-26 13:16:13 -07:00
parent 92d77bbc6e
commit 6978e93080
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
inspector_test.go
View File

@ -6,6 +6,7 @@ package asynq
import ( import (
"fmt" "fmt"
"math"
"testing" "testing"
"time" "time"
@ -768,8 +769,12 @@ func TestInspectorKillAllScheduledTasks(t *testing.T) {
t.Errorf("There are still %d entries in scheduled queue, want empty", t.Errorf("There are still %d entries in scheduled queue, want empty",
len(gotScheduled)) len(gotScheduled))
} }
// Allow Z.Score to differ by up to 2.
approxOpt := cmp.Comparer(func(a, b int64) bool {
return math.Abs(float64(a-b)) < 2
})
gotDead := asynqtest.GetDeadEntries(t, r) gotDead := asynqtest.GetDeadEntries(t, r)
if diff := cmp.Diff(tc.wantDead, gotDead, asynqtest.SortZSetEntryOpt); diff != "" { if diff := cmp.Diff(tc.wantDead, gotDead, asynqtest.SortZSetEntryOpt, approxOpt); diff != "" {
t.Errorf("mismatch in %q; (-want,+got)\n%s", base.DeadQueue, diff) t.Errorf("mismatch in %q; (-want,+got)\n%s", base.DeadQueue, diff)
} }
} }