From d9cd55351f9dd21816aaf69e2763d1bbf9cdb684 Mon Sep 17 00:00:00 2001 From: yashsinghcodes Date: Wed, 4 Dec 2024 11:11:49 +0530 Subject: [PATCH] latest build for orborus and worker --- functions/onprem/orborus/orborus.go | 4 +++- functions/onprem/worker/worker.go | 5 +++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go index 4f7a30a3..b6e7680e 100755 --- a/functions/onprem/orborus/orborus.go +++ b/functions/onprem/orborus/orborus.go @@ -2150,7 +2150,9 @@ func main() { log.Printf("[DEBUG] Starting iteration on environment %#v (default = Shuffle). Got statuscode %d from backend on first request", environment, newresp.StatusCode) } - go AutoScale(ctx) + if os.Getenv("SHUFFLE_SWARM_CONFIG") == "run" && os.Getenv("SHUFFLE_SCALE_REPLICAS") == "" { + go AutoScale(ctx) + } hasStarted = true } diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go index ae6034b3..189a619e 100644 --- a/functions/onprem/worker/worker.go +++ b/functions/onprem/worker/worker.go @@ -4129,8 +4129,9 @@ func runWebserver(listener net.Listener) { log.Printf("[DEBUG] SHUFFLE_APP_EXECUTIONS_PER_MINUTE set to value %s. Trying to overwrite default (%d)", os.Getenv("SHUFFLE_APP_EXECUTIONS_PER_MINUTE"), maxExecutionsPerMinute) } - go AutoScaleApps(ctx, dockercli, maxExecutionsPerMinute) - + if strings.ToLower(os.Getenv("SHUFFLE_SWARM_CONFIG")) == "run" || strings.ToLower(os.Getenv("SHUFFLE_APP_REPLICAS")) == "" { + go AutoScaleApps(ctx, dockercli, maxExecutionsPerMinute) + } if strings.ToLower(os.Getenv("SHUFFLE_DEBUG_MEMORY")) == "true" { r.HandleFunc("/debug/pprof/", pprof.Index) r.HandleFunc("/debug/pprof/heap", pprof.Handler("heap").ServeHTTP)