diff --git a/internal/rdb/inspect.go b/internal/rdb/inspect.go index e0ff1b0..deca68c 100644 --- a/internal/rdb/inspect.go +++ b/internal/rdb/inspect.go @@ -692,9 +692,13 @@ func (r *RDB) DeletePendingTask(qname string, id uuid.UUID) error { return err } if msg.ID == id { - if err := r.client.LRem(qkey, 1, s).Err(); err != nil { + n, err := r.client.LRem(qkey, 1, s).Result() + if err != nil { return err } + if n == 0 { + return ErrTaskNotFound + } return nil } }