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

correct execution

Browse Source
This commit is contained in:
pb 2024-08-07 12:27:29 +02:00
parent b7c4a78158
commit af9e7d8edd
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
models/workflow/workflow_mongo_accessor.go
View File

@ -35,7 +35,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
} }
if delete { if delete {
mongo.MONGOService.DeleteMultiple(map[string]interface{}{ mongo.MONGOService.DeleteMultiple(map[string]interface{}{
"workflow_id": realData.UUID, "workflow_id": id,
}, utils.WORKFLOW_EXECUTION.String()) }, utils.WORKFLOW_EXECUTION.String())
} }
if realData.Schedule != nil { if realData.Schedule != nil {
@ -62,7 +62,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
ExecDate: &s, ExecDate: &s,
EndDate: realData.Schedule.End, EndDate: realData.Schedule.End,
State: 1, State: 1,
WorkflowID: realData.UUID, WorkflowID: id,
} }
accessor.StoreOne(obj) accessor.StoreOne(obj)
} }
@ -75,7 +75,7 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
ExecDate: realData.Schedule.Start, ExecDate: realData.Schedule.Start,
EndDate: realData.Schedule.End, EndDate: realData.Schedule.End,
State: 1, State: 1,
WorkflowID: realData.UUID, WorkflowID: id,
} }
accessor.StoreOne(obj) accessor.StoreOne(obj)
} }