From b9eb0a2a8706f78aa990a9893f0651cb52823af6 Mon Sep 17 00:00:00 2001 From: Nam Huynh Date: Tue, 30 Nov 2021 23:08:19 +0700 Subject: [PATCH] append queue priority --- task.go | 1 + 1 file changed, 1 insertion(+) diff --git a/task.go b/task.go index aaa86d5..b5b93bd 100644 --- a/task.go +++ b/task.go @@ -14,6 +14,7 @@ func (i Instance) RunTask(typename string, payload []byte, priority string, retr if priority != PriorityCritical && priority != PriorityDefault && priority != PriorityLow { priority = PriorityDefault } + options = append(options, asynq.Queue(priority)) // Retry times if retryTimes < 0 {