didn't put the blocking loop in the right place for post booking
This commit is contained in:
parent
0d96cc53bf
commit
cd7ae788b1
@ -164,11 +164,11 @@ func (ws *WorkflowSchedule) Schedules(wfID string, request *tools.APIRequest) (*
|
|||||||
|
|
||||||
for _, booking := range bookings {
|
for _, booking := range bookings {
|
||||||
go ws.BookExecs(booking, request, errCh, &m)
|
go ws.BookExecs(booking, request, errCh, &m)
|
||||||
|
}
|
||||||
for i := 0; i < len(bookings); i++ {
|
|
||||||
if err := <- errCh ; err != nil {
|
for i := 0; i < len(bookings); i++ {
|
||||||
return ws, wf, executions, errors.New("could not launch the peer execution : " + fmt.Sprintf("%v", err))
|
if err := <- errCh ; err != nil {
|
||||||
}
|
return ws, wf, executions, errors.New("could not launch the peer execution : " + fmt.Sprintf("%v", err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user