From 49c5291c7b64bc41f1c0027dc5c4bb2f747969f3 Mon Sep 17 00:00:00 2001 From: Aditya <60684641+0x0elliot@users.noreply.github.com> Date: Fri, 13 Dec 2024 01:40:30 +0530 Subject: [PATCH] fix: disabling yash's autoscaling --- functions/onprem/worker/worker.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go index 189a619e..6052c9c0 100644 --- a/functions/onprem/worker/worker.go +++ b/functions/onprem/worker/worker.go @@ -4102,8 +4102,8 @@ func runWebserver(listener net.Listener) { log.Printf("[DEBUG] Running webserver config for SWARM and K8s") } /*** ENDREMOVE ***/ - var dockercli *dockerclient.Client - ctx := context.Background() + // var dockercli *dockerclient.Client + // ctx := context.Background() scaleReplicas := os.Getenv("SHUFFLE_APP_REPLICAS") if len(scaleReplicas) > 0 { tmpInt, err := strconv.Atoi(scaleReplicas) @@ -4130,7 +4130,7 @@ func runWebserver(listener net.Listener) { } if strings.ToLower(os.Getenv("SHUFFLE_SWARM_CONFIG")) == "run" || strings.ToLower(os.Getenv("SHUFFLE_APP_REPLICAS")) == "" { - go AutoScaleApps(ctx, dockercli, maxExecutionsPerMinute) + // go AutoScaleApps(ctx, dockercli, maxExecutionsPerMinute) } if strings.ToLower(os.Getenv("SHUFFLE_DEBUG_MEMORY")) == "true" { r.HandleFunc("/debug/pprof/", pprof.Index)