From bf1fbd8f4dc2a373330e029d11291f5ea0642181 Mon Sep 17 00:00:00 2001 From: admin Date: Wed, 20 Aug 2025 09:13:10 +0300 Subject: [PATCH] feat: configure Asynq server concurrency to improve task processing --- internal/tasks/server/server.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/internal/tasks/server/server.go b/internal/tasks/server/server.go index 9dc5835..f1135c9 100644 --- a/internal/tasks/server/server.go +++ b/internal/tasks/server/server.go @@ -1,12 +1,13 @@ package server import ( - "github.com/hibiken/asynq" - "github.com/jackc/pgx/v5/pgxpool" "sipro-mps/internal/config" "sipro-mps/internal/tasks/ozon" "sipro-mps/internal/tasks/types" "sipro-mps/internal/tasks/wb" + + "github.com/hibiken/asynq" + "github.com/jackc/pgx/v5/pgxpool" ) type AsynqServer struct { @@ -32,7 +33,9 @@ func (s *AsynqServer) createMux() *asynq.ServeMux { func (s *AsynqServer) Run() { srv := asynq.NewServer( asynq.RedisClientOpt{Addr: s.redisConfig.Addr, Password: s.redisConfig.Password}, - asynq.Config{}, + asynq.Config{ + Concurrency: 2, + }, ) mux := s.createMux() if err := srv.Run(mux); err != nil {