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

Worker rebuild with autodeploy of shuffle-ai

Browse Source
This commit is contained in:
Frikky
2026-02-11 12:38:31 +01:00
parent 82c95db5be
commit 136e54c8ed
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/worker/worker.go
+4 -3
View File
@@ -117,6 +117,7 @@ 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",
"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.1.0": "frikky/shuffle:shuffle-subflow_1.1.0", "shuffle-subflow:1.1.0": "frikky/shuffle:shuffle-subflow_1.1.0",
"shuffle-ai:1.1.0": "frikky/shuffle:shuffle-ai_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",
} }
@@ -1528,11 +1529,11 @@ func handleExecutionResult(workflowExecution shuffle.WorkflowExecution) {
// Rewriting them // Rewriting them
action.Parameters = []shuffle.WorkflowAppActionParameter{ action.Parameters = []shuffle.WorkflowAppActionParameter{
shuffle.WorkflowAppActionParameter{ shuffle.WorkflowAppActionParameter{
Name: "input_data", Name: "input_data",
Value: inputParamValue, Value: inputParamValue,
}, },
shuffle.WorkflowAppActionParameter{ shuffle.WorkflowAppActionParameter{
Name: "actions", Name: "actions",
Value: allowedActions, Value: allowedActions,
}, },
} }
@@ -3734,7 +3735,7 @@ func findAppInfo(image, name string, redeploy bool) (int, error) {
} }
if redeploy { if redeploy {
log.Printf("Found it! Service: %s with image %s on port %d", name, image, exposedPort) log.Printf("[INFO] Found to redeploy! Service: %s with image %s on port %d", name, image, exposedPort)
// Remove the service and redeploy it. // Remove the service and redeploy it.
// There are cases where the service doesn't update properly // There are cases where the service doesn't update properly
// Check when the last update happened. If it was within the last few minutes, skip // Check when the last update happened. If it was within the last few minutes, skip