diff --git a/task.go b/task.go index 541820c..968207d 100644 --- a/task.go +++ b/task.go @@ -1,8 +1,9 @@ package queue import ( - "github.com/hibiken/asynq" "time" + + "github.com/hibiken/asynq" ) const ( @@ -19,6 +20,7 @@ func (i Instance) RunTask(typename string, payload []byte, priority string, retr if priority != PriorityCritical && priority != PriorityDefault && priority != PriorityLow { priority = PriorityDefault } + priority = i.Config.QueuePrefix + priority options = append(options, asynq.Queue(priority)) // Retry times