fix: adding ctx to msg

prevent it from crash in some cases
vmihailenco · Nov 18, 2021 · 819b42b · 819b42b
1 parent bac023a
commit 819b42b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/redisq/queue.go b/redisq/queue.go
@@ -403,6 +403,7 @@ func (q *Queue) schedulePending(ctx context.Context) (int, error) {
 
 		xmsg := &xmsgs[0]
 		msg := new(taskq.Message)
+		msg.Ctx = ctx
 		err = unmarshalMessage(msg, xmsg)
 		if err != nil {
 			return 0, err