1 files changed, 1 insertions(+), 1 deletions(-)

M 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