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

Made orborus less verbose

Browse Source
This commit is contained in:
Frikky
2025-10-24 16:54:32 +02:00
parent 73a8531e43
commit f638baefcf
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/orborus/orborus.go
+7 -2
View File
@@ -2075,7 +2075,10 @@ func sendRemoveRequest(client *http.Client, toBeRemoved shuffle.ExecutionRequest
resultResp, err := client.Do(result) resultResp, err := client.Do(result)
if err != nil { if err != nil {
log.Printf("[ERROR] Failed making confirm request: %s", err) if !strings.Contains(fmt.Sprintf("%s", err), "timeout") {
log.Printf("[ERROR] Failed making confirm request: %s", err)
}
time.Sleep(time.Duration(sleepTime) * time.Second) time.Sleep(time.Duration(sleepTime) * time.Second)
return err return err
} }
@@ -4167,7 +4170,9 @@ func sendWorkerRequest(workflowExecution shuffle.ExecutionRequest, image string,
newresp, err := client.Do(req) newresp, err := client.Do(req)
if err != nil { if err != nil {
// Connection refused? // Connection refused?
log.Printf("[ERROR][%s] Error running worker request to %s (1): %s", workflowExecution.ExecutionId, streamUrl, err) if !strings.Contains(fmt.Sprintf("%s", err), "timeout") {
log.Printf("[ERROR][%s] Error running worker request to %s (1): %s", workflowExecution.ExecutionId, streamUrl, err)
}
if strings.Contains(fmt.Sprintf("%s", err), "connection refused") || strings.Contains(fmt.Sprintf("%s", err), "EOF") { if strings.Contains(fmt.Sprintf("%s", err), "connection refused") || strings.Contains(fmt.Sprintf("%s", err), "EOF") {
workerImage := fmt.Sprintf("ghcr.io/shuffle/shuffle-worker:%s", workerVersion) workerImage := fmt.Sprintf("ghcr.io/shuffle/shuffle-worker:%s", workerVersion)