diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index 7bda6e0..3f983e7 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -100,7 +100,10 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet execs, err := wfa.getExecutions(id, realData) if err == nil && len(execs) > 0 { for _, obj := range execs { - accessor.StoreOne(obj) + _, code, err := accessor.StoreOne(obj) + if code != 200 { + return code, err + } } } else { return 422, err