fix redis url

Author: AlexanderWangY

apps/api/cmd/api/main.go

@@ -40,9 +40,11 @@ func main() {
 	}
 
 	// Create asynq client
-	taskQueueClient := asynq.NewClient(asynq.RedisClientOpt{
-		Addr: cfg.RedisURL,
-	})
+	redisOpt, err := asynq.ParseRedisURI(cfg.RedisURL)
+	if err != nil {
+		logger.Fatal().Msg("Failed to parse REDIS_URL")
+	}
+	taskQueueClient := asynq.NewClient(redisOpt)
 
 	// Create new middleware injectable
 	mw := middleware.NewMiddleware(database, logger, cfg)

apps/api/cmd/email_worker/main.go

@@ -16,8 +16,13 @@ func main() {
 	logger := logger.New()
 	cfg := config.Load()
 
+	redisOpt, err := asynq.ParseRedisURI(cfg.RedisURL)
+	if err != nil {
+		logger.Fatal().Msg("Failed to parse REDIS_URL")
+	}
+
 	srv := asynq.NewServer(
-		asynq.RedisClientOpt{Addr: cfg.RedisURL},
+		redisOpt,
 		asynq.Config{
 			Concurrency: 10,
 			Queues: map[string]int{