From 022aca272dd4cdaea9ce24286500ddb81272e886 Mon Sep 17 00:00:00 2001 From: Peter Sanchez Date: Wed, 31 Aug 2022 09:11:56 -0600 Subject: [PATCH] Fixing context assignment for task queues --- server/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/server.go b/server/server.go index 19b44be..1340138 100644 --- a/server/server.go +++ b/server/server.go @@ -322,9 +322,9 @@ func (s *Server) WithMiddleware(middlewares ...echo.MiddlewareFunc) *Server { // WithQueues add dowork task queues for this server to manage func (s *Server) WithQueues(queues ...*work.Queue) *Server { - ctx := context.Background() s.queues = append(s.queues, queues...) for _, queue := range queues { + ctx := context.Background() queue.Start(ctx) } return s -- 2.45.2