append queue priority

2021-11-30 23:08:19 +07:00 · 2021-11-30 23:08:19 +07:00 · b9eb0a2a87
parent ed3d068e80
commit b9eb0a2a87
1 changed files with 1 additions and 0 deletions
--- 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 {