diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index f30e220..b31f6b9 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -36,6 +36,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet if delete { mongo.MONGOService.DeleteMultiple(map[string]interface{}{ "workflow_id": id, + "state": 1, }, utils.WORKFLOW_EXECUTION.String()) } if realData.Schedule != nil {