diff --git a/models/workflow_execution/workflow_scheduler.go b/models/workflow_execution/workflow_scheduler.go index 16ee325..d956092 100644 --- a/models/workflow_execution/workflow_scheduler.go +++ b/models/workflow_execution/workflow_scheduler.go @@ -164,11 +164,11 @@ func (ws *WorkflowSchedule) Schedules(wfID string, request *tools.APIRequest) (* for _, booking := range bookings { go ws.BookExecs(booking, request, errCh, &m) - - for i := 0; i < len(bookings); i++ { - if err := <- errCh ; err != nil { - return ws, wf, executions, errors.New("could not launch the peer execution : " + fmt.Sprintf("%v", err)) - } + } + + for i := 0; i < len(bookings); i++ { + if err := <- errCh ; err != nil { + return ws, wf, executions, errors.New("could not launch the peer execution : " + fmt.Sprintf("%v", err)) } }