Fix: return after publishing error response in scheduler.SubmitAsyncRequest()

matteonardelli · matteonardelli · commit 3aae940bbeac · 2025-07-31T07:53:33.000Z
diff --git a/internal/scheduling/scheduler.go b/internal/scheduling/scheduler.go
@@ -134,6 +134,7 @@ func SubmitAsyncRequest(r *function.Request) {
 		report, err := Execute(schedDecision.cont, &schedRequest, schedDecision.useWarm)
 		if err != nil {
 			publishAsyncResponse(r.Id(), function.Response{Success: false})
+			return
 		}
 		publishAsyncResponse(r.Id(), function.Response{Success: true, ExecutionReport: report})
 	}

Original file line number	Diff line number	Diff line change
`@@ -134,6 +134,7 @@ func SubmitAsyncRequest(r *function.Request) {`
`134`	`134`	`report, err := Execute(schedDecision.cont, &schedRequest, schedDecision.useWarm)`
`135`	`135`	`if err != nil {`
`136`	`136`	`publishAsyncResponse(r.Id(), function.Response{Success: false})`
	`137`	`+ return`
`137`	`138`	`}`
`138`	`139`	`publishAsyncResponse(r.Id(), function.Response{Success: true, ExecutionReport: report})`
`139`	`140`	`}`