Add concurrency to HadesScheduler Config (#55)

HadesScheduler/main.go

@@ -19,22 +19,27 @@ type JobScheduler interface {
 	ScheduleJob(ctx context.Context, job payload.QueuePayload) error
 }
 
+type HadesSchedulerConfig struct {
+	Concurrency uint `env:"CONCURRENCY" envDefault:"1"`
+	RedisConfig utils.RedisConfig
+}
+
 func main() {
 	if is_debug := os.Getenv("DEBUG"); is_debug == "true" {
 		log.SetLevel(log.DebugLevel)
 		log.Warn("DEBUG MODE ENABLED")
 	}
 
-	var cfg utils.RedisConfig
+	var cfg HadesSchedulerConfig
 	utils.LoadConfig(&cfg)
 
 	var executorCfg utils.ExecutorConfig
 	utils.LoadConfig(&executorCfg)
 	log.Debug("Executor config: ", executorCfg)
 
 	var err error
-	AsynqServer = asynq.NewServer(asynq.RedisClientOpt{Addr: cfg.Addr}, asynq.Config{
-		Concurrency: 1,
+	AsynqServer = asynq.NewServer(asynq.RedisClientOpt{Addr: cfg.RedisConfig.Addr}, asynq.Config{
+		Concurrency: int(cfg.Concurrency),
 		Queues: map[string]int{
 			"critical": 5,
 			"high":     4,