diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index 81b8dfc..f30e220 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -35,7 +35,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet } if delete { mongo.MONGOService.DeleteMultiple(map[string]interface{}{ - "workflow_id": realData.UUID, + "workflow_id": id, }, utils.WORKFLOW_EXECUTION.String()) } if realData.Schedule != nil { @@ -62,7 +62,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet ExecDate: &s, EndDate: realData.Schedule.End, State: 1, - WorkflowID: realData.UUID, + WorkflowID: id, } accessor.StoreOne(obj) } @@ -75,7 +75,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet ExecDate: realData.Schedule.Start, EndDate: realData.Schedule.End, State: 1, - WorkflowID: realData.UUID, + WorkflowID: id, } accessor.StoreOne(obj) }