diff --git a/internal/rdb/inspect.go b/internal/rdb/inspect.go index 82d3577..d9c3733 100644 --- a/internal/rdb/inspect.go +++ b/internal/rdb/inspect.go @@ -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.Error() == "QUEUE NOT EMPTY" { return &ErrQueueNotEmpty{qname} - } else { - return err } + return err } return r.client.SRem(base.AllQueues, qname).Err() } diff --git a/internal/rdb/inspect_test.go b/internal/rdb/inspect_test.go index 3dd53d4..d838423 100644 --- a/internal/rdb/inspect_test.go +++ b/internal/rdb/inspect_test.go @@ -3017,7 +3017,7 @@ func TestWriteListClearSchedulerEntries(t *testing.T) { schedulerID := "127.0.0.1:9876:abc123" data := []*base.SchedulerEntry{ - &base.SchedulerEntry{ + { Spec: "* * * * *", Type: "foo", Payload: nil, @@ -3025,7 +3025,7 @@ func TestWriteListClearSchedulerEntries(t *testing.T) { Next: now.Add(5 * time.Hour), Prev: now.Add(-2 * time.Hour), }, - &base.SchedulerEntry{ + { Spec: "@every 20m", Type: "bar", Payload: map[string]interface{}{"fiz": "baz"},