Merge branch '2.0.0' into improve-app-builder

backend/app_sdk/app_base.py

@@ -1645,6 +1645,25 @@ class AppBase:
             #return value.json()
             return {"success": False}
 
+    def update_file(self, file_id, content):
+        full_execution = self.full_execution
+        workflow_id = full_execution["workflow"]["id"]
+        org_id = full_execution["workflow"]["execution_org"]["id"]
+
+        new_headers = {
+            "Authorization": f"Bearer {self.authorization}",
+            "User-Agent": "Shuffle 1.1.0",
+        }
+
+        upload_path = "/api/v1/files/%s/edit?execution_id=%s" % (file_id, full_execution["execution_id"])
+
+        files={"shuffle_file": ("filename", content)}
+
+        ret = requests.put("%s%s" % (self.url, upload_path), files=files, headers=new_headers, verify=False, proxies=self.proxy_config)
+        print(ret.status_code)
+        return ret.json()
+
+
     # Wrapper for set_files
     def set_file(self, infiles):
         return self.set_files(infiles)

backend/go-app/go.mod

@@ -20,7 +20,7 @@ require (
 	github.com/gorilla/mux v1.8.1
 	github.com/h2non/filetype v1.1.3
 	github.com/satori/go.uuid v1.2.0
-	github.com/shuffle/shuffle-shared v0.6.77
+	github.com/shuffle/shuffle-shared v0.6.78
 	golang.org/x/crypto v0.22.0
 	google.golang.org/api v0.176.1
 	google.golang.org/grpc v1.63.2

functions/onprem/orborus/orborus.go

@@ -3726,7 +3726,9 @@ func sendWorkerRequest(workflowExecution shuffle.ExecutionRequest, image string,
 
 	newresp, err := client.Do(req)
 	if err != nil {
+		// Connection refused?
 		log.Printf("[ERROR] Error running worker request to %s (1): %s", streamUrl, err)
+
 		if strings.Contains(fmt.Sprintf("%s", err), "connection refused") || strings.Contains(fmt.Sprintf("%s", err), "EOF") {
 			workerImage := fmt.Sprintf("%s/%s/shuffle-worker:%s", baseimageregistry, baseimagename, workerVersion)
 

functions/onprem/worker/worker.go

@@ -1301,9 +1301,6 @@ func handleExecutionResult(workflowExecution shuffle.WorkflowExecution) {
 			log.Printf("[ERROR] Unable to create docker client (3): %s", err)
 			return
 		}
-	}
-
-	if isKubernetes == "true" {
 		defer dockercli.Close()
 	}