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

cleaned up the agent api calling code block

Browse Source
This commit is contained in:
Hari Krishna
2026-02-09 21:18:38 +05:30
parent efaa3e32bc
commit 6eb783c1b1
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
functions/onprem/worker/worker.go
+13 -8
View File
@@ -1498,10 +1498,15 @@ func handleExecutionResult(workflowExecution shuffle.WorkflowExecution) {
action, _ = singul.HandleSingulStartnode(workflowExecution, action, []string{}) action, _ = singul.HandleSingulStartnode(workflowExecution, action, []string{})
parsedAppname := strings.Replace(strings.ToLower(action.AppName), " ", "-", -1) parsedAppname := strings.Replace(strings.ToLower(action.AppName), " ", "-", -1)
// if strings.ToLower(parsedAppname) == "singul" {
// parsedAppname = "shuffle-ai"
// appversion = "1.0.0"
// appname = "shuffle-ai"
// }
if parsedAppname == "ai-agent" { if parsedAppname == "ai-agent" {
log.Printf("[INFO][%s] Running AI Agent action %s via backend API", workflowExecution.ExecutionId, action.ID) log.Printf("[INFO][%s] Running AI Agent action %s via backend API", workflowExecution.ExecutionId, action.ID)
// Call the backend API - it will start the agent ASYNC and return immediately
fullUrl := fmt.Sprintf("%s/api/v1/agent/hybrid/execute?execution_id=%s&authorization=%s", fullUrl := fmt.Sprintf("%s/api/v1/agent/hybrid/execute?execution_id=%s&authorization=%s",
baseUrl, workflowExecution.ExecutionId, workflowExecution.Authorization) baseUrl, workflowExecution.ExecutionId, workflowExecution.Authorization)
@@ -1545,14 +1550,14 @@ func handleExecutionResult(workflowExecution shuffle.WorkflowExecution) {
} }
defer resp.Body.Close() defer resp.Body.Close()
body, err := ioutil.ReadAll(resp.Body) // body, err := ioutil.ReadAll(resp.Body)
if err != nil { // if err != nil {
log.Printf("[ERROR][%s] Failed reading AI Agent response: %s", workflowExecution.ExecutionId, err) // log.Printf("[ERROR][%s] Failed reading AI Agent response: %s", workflowExecution.ExecutionId, err)
} else { // } else {
log.Printf("[INFO][%s] AI Agent triggered: %s", workflowExecution.ExecutionId, string(body)) // log.Printf("[INFO][%s] AI Agent triggered: %s", workflowExecution.ExecutionId, string(body))
} // }
log.Printf("[INFO][%s] Worker exiting cleanly (exit 0) - backend will requeue when agent completes", workflowExecution.ExecutionId) log.Printf("[INFO][%s] Worker exiting (exit 0) - backend will requeue when agent completes", workflowExecution.ExecutionId)
os.Exit(0) os.Exit(0)
} }