From 61d30d9fb289715739ad62aec7fd2b4b91da3a49 Mon Sep 17 00:00:00 2001
From: Frikky <frikky@shuffler.io>
Date: Tue, 9 Sep 2025 16:00:53 +0200
Subject: [PATCH] Minor print fixes to orborus/worker

---
 docker-compose.yml                  | 8 ++++++--
 functions/onprem/orborus/orborus.go | 4 ++--
 functions/onprem/worker/worker.go   | 2 +-
 3 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/docker-compose.yml b/docker-compose.yml
index ce3de3f6..c1c27efb 100755
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -95,12 +95,16 @@ services:
   #  image: memcached:latest
   #  container_name: shuffle-cache
   #  hostname: shuffle-cache
-  #  mem_limit: 1024m
+  #  command: memcached -m 2048 -c 2500
   #  environment:
-  #    - MEMCACHED_MEMORY=1024
+  #    - MEMCACHED_MEMORY=2048
   #    - MEMCACHED_MAX_CONNECTIONS=2500
   #  ports:
   #    - 11211:11211
+  #  deploy:
+  #    resources:
+  #      limits:
+  #        memory: 2048M
   
   #docker-socket-proxy:
   #  image: tecnativa/docker-socket-proxy
diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go
index a6435b65..d15ae33a 100755
--- a/functions/onprem/orborus/orborus.go
+++ b/functions/onprem/orborus/orborus.go
@@ -195,10 +195,10 @@ func getThisContainerId() {
 	if containerId == "" {
 		if containerName != "" {
 			containerId = containerName
-			log.Printf("[INFO] Falling back to CONTAINER_NAME as container ID")
+			log.Printf("[INFO] Falling back to ORBORUS_CONTAINER_NAME as container ID")
 		} else {
 			containerId = "shuffle-orborus"
-			log.Printf(`[WARNING] CONTAINER_NAME is not set. Falling back to default name "%s" as container ID`, containerId)
+			log.Printf(`[WARNING] ORBORUS_CONTAINER_NAME env is not set. Falling back to default name "%s" as container ID. This may cause issues on the same server`, containerId)
 		}
 	}
 
diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go
index 265173a5..b598c89f 100644
--- a/functions/onprem/worker/worker.go
+++ b/functions/onprem/worker/worker.go
@@ -4028,7 +4028,7 @@ func getStreamResultsWrapper(client *http.Client, req *http.Request, workflowExe
 	if newresp.StatusCode != 200 {
 		log.Printf("[ERROR] StatusCode (1): %d - %s", newresp.StatusCode, string(body))
 		time.Sleep(time.Duration(sleepTime) * time.Second)
-		return environments, errors.New(fmt.Sprintf("Bad status code: %d", newresp.StatusCode))
+		return environments, errors.New(fmt.Sprintf("Bad status code from backend: %d", newresp.StatusCode))
 	}
 
 	err = json.Unmarshal(body, &workflowExecution)