From e8e401578f3aff91457d79ec0f610ca91ee7e444 Mon Sep 17 00:00:00 2001
From: Ken Hibino <ken.hibino7@gmail.com>
Date: Tue, 19 Jan 2021 20:56:58 -0800
Subject: [PATCH] Minor fix

---
 internal/rdb/inspect.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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
 		}
 	}