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