From f638baefcfee24ff08c3a5aebccacafc7e7ac7af Mon Sep 17 00:00:00 2001 From: Frikky Date: Fri, 24 Oct 2025 16:54:32 +0200 Subject: [PATCH] Made orborus less verbose --- functions/onprem/orborus/orborus.go | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go index 02210982..d1af43a2 100755 --- a/functions/onprem/orborus/orborus.go +++ b/functions/onprem/orborus/orborus.go @@ -2075,7 +2075,10 @@ func sendRemoveRequest(client *http.Client, toBeRemoved shuffle.ExecutionRequest resultResp, err := client.Do(result) 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) return err } @@ -4167,7 +4170,9 @@ func sendWorkerRequest(workflowExecution shuffle.ExecutionRequest, image string, newresp, err := client.Do(req) if err != nil { // 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") { workerImage := fmt.Sprintf("ghcr.io/shuffle/shuffle-worker:%s", workerVersion)