Merge pull request #1841 from BogatikovM/apps_scaling

fix apps scaling for k8s shuffle
2025-10-16 20:30:39 +02:00
parent 696bb66c83 dde6099b90
commit e4c290b79c
2 changed files with 6 additions and 2 deletions
@@ -1154,6 +1154,10 @@ func deployK8sWorker(image string, identifier string, env []string) error {
 		env = append(env, fmt.Sprintf("SHUFFLE_LOGS_DISABLED=%s", os.Getenv("SHUFFLE_LOGS_DISABLED")))
 	}

+	if len(os.Getenv("SHUFFLE_APP_REPLICAS")) > 0 {
+		env = append(env, fmt.Sprintf("SHUFFLE_APP_REPLICAS=%s", os.Getenv("SHUFFLE_APP_REPLICAS")))
+	}
+
 	clientset, _, err := shuffle.GetKubernetesClient()
 	if err != nil {
 		log.Printf("[ERROR] Error getting kubernetes client:", err)