Merge pull request #1677 from Shuffle/main

Sync with main
This commit is contained in:
Frikky
2025-04-03 23:18:12 +02:00
committed by GitHub
2 changed files with 18 additions and 4 deletions
+4 -4
View File
@@ -20,19 +20,19 @@ jobs:
include: include:
- app: frontend - app: frontend
path: frontend path: frontend
version: 2.0.1 version: latest
experimental: true experimental: true
- app: backend - app: backend
path: backend path: backend
version: 2.0.1 version: latest
experimental: true experimental: true
- app: orborus - app: orborus
path: functions/onprem/orborus path: functions/onprem/orborus
version: 2.0.1 version: latest
experimental: true experimental: true
- app: worker - app: worker
path: functions/onprem/worker path: functions/onprem/worker
version: 2.0.1 version: latest
experimental: true experimental: true
steps: steps:
- name: Checkout - name: Checkout
+14
View File
@@ -1449,6 +1449,20 @@ func executeWorkflow(resp http.ResponseWriter, request *http.Request) {
} }
resp.WriteHeader(200) resp.WriteHeader(200)
// Check for "wait" query if it's true
wait, waitok := request.URL.Query()["wait"]
if waitok && wait[0] == "true" {
returnBody := shuffle.HandleRetValidation(ctx, workflowExecution, 1)
returnBytes, err := json.Marshal(returnBody)
if err != nil {
log.Printf("[ERROR] Failed to marshal retStruct in single execution: %s", err)
}
resp.Write(returnBytes)
return
}
resp.Write([]byte(fmt.Sprintf(`{"success": true, "execution_id": "%s", "authorization": "%s"}`, workflowExecution.ExecutionId, workflowExecution.Authorization))) resp.Write([]byte(fmt.Sprintf(`{"success": true, "execution_id": "%s", "authorization": "%s"}`, workflowExecution.ExecutionId, workflowExecution.Authorization)))
return return
} }