core/oc-lib
5
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

test booking

Browse Source
This commit is contained in:
mr 2024-09-24 09:29:59 +02:00
parent 92bb274d03
commit 5c9adcf597
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
models/workflow/workflow_mongo_accessor.go
View File

@ -215,6 +215,8 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
if err != nil { if err != nil {
return 409, err // if the booking fails, return an error for integrity between peers return 409, err // if the booking fails, return an error for integrity between peers
} }
fmt.Println("BOOKING2", err, delete)
if delete { // if delete is set to true, delete the executions if delete { // if delete is set to true, delete the executions
mongo.MONGOService.DeleteMultiple(map[string]interface{}{ mongo.MONGOService.DeleteMultiple(map[string]interface{}{
"workflow_id": id, "workflow_id": id,
@ -224,9 +226,11 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
nats.SetNATSPub(utils.WORKFLOW.String(), tools.REMOVE, realData) nats.SetNATSPub(utils.WORKFLOW.String(), tools.REMOVE, realData)
return 200, nil return 200, nil
} }
fmt.Println("EXECS", err, len(execs))
if len(execs) > 0 { // if the executions are set, store them if len(execs) > 0 { // if the executions are set, store them
for _, obj := range execs { for _, obj := range execs {
_, code, err := accessor.StoreOne(obj) _, code, err := accessor.StoreOne(obj)
fmt.Println("EXECS LOOP", err, code)
if code != 200 { if code != 200 {
return code, err return code, err
} }