marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: disabling yash's autoscaling

Browse Source
This commit is contained in:
Aditya
2024-12-13 01:40:30 +05:30
parent 0368356a8d
commit 49c5291c7b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/worker/worker.go
+3 -3
View File
@@ -4102,8 +4102,8 @@ func runWebserver(listener net.Listener) {
log.Printf("[DEBUG] Running webserver config for SWARM and K8s") log.Printf("[DEBUG] Running webserver config for SWARM and K8s")
} }
/*** ENDREMOVE ***/ /*** ENDREMOVE ***/
var dockercli *dockerclient.Client // var dockercli *dockerclient.Client
ctx := context.Background() // ctx := context.Background()
scaleReplicas := os.Getenv("SHUFFLE_APP_REPLICAS") scaleReplicas := os.Getenv("SHUFFLE_APP_REPLICAS")
if len(scaleReplicas) > 0 { if len(scaleReplicas) > 0 {
tmpInt, err := strconv.Atoi(scaleReplicas) 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")) == "" { 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" { if strings.ToLower(os.Getenv("SHUFFLE_DEBUG_MEMORY")) == "true" {
r.HandleFunc("/debug/pprof/", pprof.Index) r.HandleFunc("/debug/pprof/", pprof.Index)