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 {