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

return an error in http request

Browse Source
This commit is contained in:
yashsinghcodes
2024-10-15 23:33:36 +05:30
parent b6a951ee82
commit cbf81685f2
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/worker/worker.go
+2 -5
View File
@@ -3783,11 +3783,6 @@ func checkUnfinished(resp http.ResponseWriter, request *http.Request, execReques
ctx := context.Background() ctx := context.Background()
exec, err := shuffle.GetWorkflowExecution(ctx, execRequest.ExecutionId) exec, err := shuffle.GetWorkflowExecution(ctx, execRequest.ExecutionId)
log.Printf("[DEBUG][%s] Rechecking execution and it's status to send to backend IF the status is EXECUTING (%s - %d/%d finished)", execRequest.ExecutionId, exec.Status, len(exec.Results), len(exec.Workflow.Actions)) log.Printf("[DEBUG][%s] Rechecking execution and it's status to send to backend IF the status is EXECUTING (%s - %d/%d finished)", execRequest.ExecutionId, exec.Status, len(exec.Results), len(exec.Workflow.Actions))
if err != nil {
log.Printf("[ERROR][%s] Got error: %s", execRequest.ExecutionId, err)
handleRunExecution(resp, request)
return
}
// FIXMe: Does this create issue with infinite loops? // FIXMe: Does this create issue with infinite loops?
// Usually caused by issue during startup // Usually caused by issue during startup
@@ -3883,6 +3878,8 @@ func handleRunExecution(resp http.ResponseWriter, request *http.Request) {
) )
if err != nil { if err != nil {
log.Printf("[ERROR][%s] Failed to create a new request", execRequest.ExecutionId) log.Printf("[ERROR][%s] Failed to create a new request", execRequest.ExecutionId)
resp.WriteHeader(401)
resp.Write([]byte(fmt.Sprintf(`{"success": false, "reason": "%s"}`, err)))
return return
} }