workflow scheduler create booking with a booking execution lot id
This commit is contained in:
parent
945b7a893e
commit
7d03676ac2
@ -111,13 +111,11 @@ func (ws *WorkflowSchedule) Schedules(wfID string, request *tools.APIRequest) (*
|
|||||||
return ws, nil, []*WorkflowExecution{}, errors.New("no path found")
|
return ws, nil, []*WorkflowExecution{}, errors.New("no path found")
|
||||||
}
|
}
|
||||||
ok, wf, executions, err := ws.CheckBooking(wfID, request)
|
ok, wf, executions, err := ws.CheckBooking(wfID, request)
|
||||||
if !ok || err != nil {
|
|
||||||
return ws, nil, []*WorkflowExecution{}, errors.New("could not book the workflow : " + fmt.Sprintf("%v", err))
|
|
||||||
}
|
|
||||||
|
|
||||||
ws.Workflow = wf
|
|
||||||
ws.WorkflowExecution = executions
|
ws.WorkflowExecution = executions
|
||||||
|
if !ok || err != nil {
|
||||||
|
return ws, nil, executions, errors.New("could not book the workflow : " + fmt.Sprintf("%v", err))
|
||||||
|
}
|
||||||
|
ws.Workflow = wf
|
||||||
for _, exec := range executions {
|
for _, exec := range executions {
|
||||||
err := exec.PurgeDraft(request)
|
err := exec.PurgeDraft(request)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user