go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2025-04-22 16:50:18 +08:00
Code Issues Projects Releases Wiki Activity

Minor lint error fix

Browse Source
This commit is contained in:
Ken Hibino 2021-01-18 13:42:40 -08:00
parent af920be7ee
commit 9061fff86e
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
internal/rdb/inspect.go
View File

@ -824,9 +824,8 @@ func (r *RDB) RemoveQueue(qname string, force bool) error {
if err := script.Run(r.client, keys).Err(); err != nil { if err := script.Run(r.client, keys).Err(); err != nil {
if err.Error() == "QUEUE NOT EMPTY" { if err.Error() == "QUEUE NOT EMPTY" {
return &ErrQueueNotEmpty{qname} return &ErrQueueNotEmpty{qname}
} else {
return err
} }
return err
} }
return r.client.SRem(base.AllQueues, qname).Err() return r.client.SRem(base.AllQueues, qname).Err()
} }

4
internal/rdb/inspect_test.go
View File

@ -3017,7 +3017,7 @@ func TestWriteListClearSchedulerEntries(t *testing.T) {
schedulerID := "127.0.0.1:9876:abc123" schedulerID := "127.0.0.1:9876:abc123"
data := []*base.SchedulerEntry{ data := []*base.SchedulerEntry{
&base.SchedulerEntry{ {
Spec: "* * * * *", Spec: "* * * * *",
Type: "foo", Type: "foo",
Payload: nil, Payload: nil,
@ -3025,7 +3025,7 @@ func TestWriteListClearSchedulerEntries(t *testing.T) {
Next: now.Add(5 * time.Hour), Next: now.Add(5 * time.Hour),
Prev: now.Add(-2 * time.Hour), Prev: now.Add(-2 * time.Hour),
}, },
&base.SchedulerEntry{ {
Spec: "@every 20m", Spec: "@every 20m",
Type: "bar", Type: "bar",
Payload: map[string]interface{}{"fiz": "baz"}, Payload: map[string]interface{}{"fiz": "baz"},