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

removed debug logs which are not important

Browse Source
This commit is contained in:
yashsinghcodes
2024-12-02 23:23:12 +05:30
parent 9746829253
commit 6c7cbc2790
2 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/orborus/orborus.go
-1
View File
@@ -2624,7 +2624,6 @@ func deployTenzirNode() error {
err := checkTenzirNode() err := checkTenzirNode()
if err == nil { if err == nil {
log.Printf("[INFO] Tenzir Node is already running")
return nil return nil
} }
functions/onprem/worker/worker.go
+5 -7
View File
@@ -104,11 +104,11 @@ var window = shuffle.NewTimeWindow(10 * time.Second)
// Images to be autodeployed in the latest version of Shuffle. // Images to be autodeployed in the latest version of Shuffle.
var autoDeploy = map[string]string{ var autoDeploy = map[string]string{
"http:1.4.0": "frikky/shuffle:http_1.4.0", "http:1.4.0": "frikky/shuffle:http_1.4.0",
"http:1.3.0": "frikky/shuffle:http_1.3.0", "http:1.3.0": "frikky/shuffle:http_1.3.0",
"shuffle-tools:1.2.0": "frikky/shuffle:shuffle-tools_1.2.0", "shuffle-tools:1.2.0": "frikky/shuffle:shuffle-tools_1.2.0",
"shuffle-subflow:1.0.0": "frikky/shuffle:shuffle-subflow_1.0.0", "shuffle-subflow:1.0.0": "frikky/shuffle:shuffle-subflow_1.0.0",
"shuffle-subflow:1.1.0": "frikky/shuffle:shuffle-subflow_1.1.0", "shuffle-subflow:1.1.0": "frikky/shuffle:shuffle-subflow_1.1.0",
"shuffle-tools-fork:1.0.0": "frikky/shuffle:shuffle-tools-fork_1.0.0", "shuffle-tools-fork:1.0.0": "frikky/shuffle:shuffle-tools-fork_1.0.0",
} }
@@ -4179,8 +4179,6 @@ func AutoScaleApps(ctx context.Context, client *dockerclient.Client, maxExecutio
j := numberOfApps(ctx, client) j := numberOfApps(ctx, client)
workers := numberOfWorkers(ctx, client) workers := numberOfWorkers(ctx, client)
execPerMin := maxExecutionsPerMinute / workers execPerMin := maxExecutionsPerMinute / workers
log.Printf("[DEBUG] Running with %d workers\n\n\n\n\n", workers)
if count >= execPerMin { if count >= execPerMin {
log.Printf("[DEBUG] Too many executions per minute (%d). Scaling down to %d", count, execPerMin) log.Printf("[DEBUG] Too many executions per minute (%d). Scaling down to %d", count, execPerMin)
scaleApps(ctx, client, uint64(j+1)) scaleApps(ctx, client, uint64(j+1))