From 3f10e97e302449da5ede756975db4a20153644dd Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Fri, 26 Feb 2021 06:39:51 -0800 Subject: [PATCH] Fix inspector test --- inspeq/inspector_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/inspeq/inspector_test.go b/inspeq/inspector_test.go index 898bd54..8345449 100644 --- a/inspeq/inspector_test.go +++ b/inspeq/inspector_test.go @@ -518,8 +518,8 @@ func TestInspectorListPendingTasks(t *testing.T) { defer r.Close() m1 := h.NewTaskMessage("task1", nil) m2 := h.NewTaskMessage("task2", nil) - m3 := h.NewTaskMessage("task3", nil) - m4 := h.NewTaskMessage("task4", nil) + m3 := h.NewTaskMessageWithQueue("task3", nil, "critical") + m4 := h.NewTaskMessageWithQueue("task4", nil, "low") inspector := New(getRedisConnOpt(t)) @@ -587,8 +587,8 @@ func TestInspectorListActiveTasks(t *testing.T) { defer r.Close() m1 := h.NewTaskMessage("task1", nil) m2 := h.NewTaskMessage("task2", nil) - m3 := h.NewTaskMessage("task3", nil) - m4 := h.NewTaskMessage("task4", nil) + m3 := h.NewTaskMessageWithQueue("task3", nil, "custom") + m4 := h.NewTaskMessageWithQueue("task4", nil, "custom") inspector := New(getRedisConnOpt(t))