diff --git a/models/workflow_execution/workflow_scheduler.go b/models/workflow_execution/workflow_scheduler.go index 33743cf..eaf983c 100644 --- a/models/workflow_execution/workflow_scheduler.go +++ b/models/workflow_execution/workflow_scheduler.go @@ -82,18 +82,18 @@ func (ws *WorkflowSchedule) CheckBooking(wfID string, request *tools.APIRequest) for i, exec := range execs { l.Debug().Msg("looping throughs execs : " + string(i)) bookings = append(bookings, exec.Book(ws.UUID, wfID, priceds)...) - for _, b := range bookings { - meth := request.Caller.URLS[tools.BOOKING][tools.GET] - meth = strings.ReplaceAll(meth, ":id", b.ResourceID) - meth = strings.ReplaceAll(meth, ":start_date", b.ExpectedStartDate.Format("2006-01-02T15:04:05")) - meth = strings.ReplaceAll(meth, ":end_date", b.ExpectedEndDate.Format("2006-01-02T15:04:05")) - request.Caller.URLS[tools.BOOKING][tools.GET] = meth - l.Debug().Msg("Get booking on" + b.DestPeerID) - _, err := (&peer.Peer{}).LaunchPeerExecution(b.DestPeerID, b.ResourceID, tools.BOOKING, tools.GET, nil, request.Caller) - l.Debug().Msg("Received response from Get booking on " + b.DestPeerID) - if err != nil { - return false, wf, execs, bookings, err - } + } + for _, b := range bookings { + meth := request.Caller.URLS[tools.BOOKING][tools.GET] + meth = strings.ReplaceAll(meth, ":id", b.ResourceID) + meth = strings.ReplaceAll(meth, ":start_date", b.ExpectedStartDate.Format("2006-01-02T15:04:05")) + meth = strings.ReplaceAll(meth, ":end_date", b.ExpectedEndDate.Format("2006-01-02T15:04:05")) + request.Caller.URLS[tools.BOOKING][tools.GET] = meth + l.Debug().Msg("Get booking on" + b.DestPeerID) + _, err := (&peer.Peer{}).LaunchPeerExecution(b.DestPeerID, b.ResourceID, tools.BOOKING, tools.GET, nil, request.Caller) + l.Debug().Msg("Received response from Get booking on " + b.DestPeerID) + if err != nil { + return false, wf, execs, bookings, err } }