go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-11-10 11:31:58 +08:00
Code Issues Projects Releases Wiki Activity

Fix errors in inspector tests

Browse Source
This commit is contained in:
Ken Hibino 2020-08-19 05:45:02 -07:00
parent 4037b41479
commit fad0696828
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
inspector_test.go
View File

@ -329,6 +329,7 @@ func createScheduledTask(z base.Z) *ScheduledTask {
ID: msg.ID.String(), ID: msg.ID.String(),
Queue: msg.Queue, Queue: msg.Queue,
NextEnqueueAt: time.Unix(z.Score, 0), NextEnqueueAt: time.Unix(z.Score, 0),
score: z.Score,
} }
} }
@ -406,6 +407,7 @@ func createRetryTask(z base.Z) *RetryTask {
MaxRetry: msg.Retry, MaxRetry: msg.Retry,
Retried: msg.Retried, Retried: msg.Retried,
ErrorMsg: msg.ErrorMsg, ErrorMsg: msg.ErrorMsg,
score: z.Score,
} }
} }
@ -484,6 +486,7 @@ func createDeadTask(z base.Z) *DeadTask {
Retried: msg.Retried, Retried: msg.Retried,
LastFailedAt: time.Unix(z.Score, 0), LastFailedAt: time.Unix(z.Score, 0),
ErrorMsg: msg.ErrorMsg, ErrorMsg: msg.ErrorMsg,
score: z.Score,
} }
} }
@ -810,7 +813,7 @@ func TestInspectorDeleteAllDeadTasks(t *testing.T) {
t.Errorf("DeleteAllDeadTasks(%q) = %d, want %d", tc.qname, got, tc.want) t.Errorf("DeleteAllDeadTasks(%q) = %d, want %d", tc.qname, got, tc.want)
} }
for qname, want := range tc.wantDead { for qname, want := range tc.wantDead {
gotDead := asynqtest.GetDeadEntries(t, r, tc.qname) gotDead := asynqtest.GetDeadEntries(t, r, qname)
if diff := cmp.Diff(want, gotDead, asynqtest.SortZSetEntryOpt); diff != "" { if diff := cmp.Diff(want, gotDead, asynqtest.SortZSetEntryOpt); diff != "" {
t.Errorf("unexpected dead tasks in queue %q: (-want, +got)\n%s", qname, diff) t.Errorf("unexpected dead tasks in queue %q: (-want, +got)\n%s", qname, diff)
} }
@ -1255,8 +1258,8 @@ func TestInspectorEnqueueAllRetryTasks(t *testing.T) {
}, },
wantEnqueued: map[string][]*base.TaskMessage{ wantEnqueued: map[string][]*base.TaskMessage{
"default": {m4, m1}, "default": {m4, m1},
"critical": {m2}, "critical": {},
"low": {m3}, "low": {},
}, },
}, },
{ {
@ -1462,7 +1465,6 @@ func TestInspectorDeleteTaskByKeyDeletesScheduledTask(t *testing.T) {
if err := inspector.DeleteTaskByKey(tc.qname, tc.key); err != nil { if err := inspector.DeleteTaskByKey(tc.qname, tc.key); err != nil {
t.Errorf("DeleteTaskByKey(%q, %q) returned error: %v", tc.qname, tc.key, err) t.Errorf("DeleteTaskByKey(%q, %q) returned error: %v", tc.qname, tc.key, err)
continue
} }
for qname, want := range tc.wantScheduled { for qname, want := range tc.wantScheduled {
gotScheduled := asynqtest.GetScheduledEntries(t, r, qname) gotScheduled := asynqtest.GetScheduledEntries(t, r, qname)