core/oc-schedulerd
6
0
Fork 0
Code Issues 7 Pull Requests Packages Projects Releases Wiki Activity

Scheduled Complex Workflow Event

Browse Source
This commit is contained in:
mr
2026-03-12 11:26:24 +01:00
parent dbc41f0326
commit ce3425e9eb
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
daemons/schedule_manager.go
View File

@@ -9,6 +9,7 @@ import (
oclib "cloud.o-forge.io/core/oc-lib" oclib "cloud.o-forge.io/core/oc-lib"
"cloud.o-forge.io/core/oc-lib/dbs" "cloud.o-forge.io/core/oc-lib/dbs"
"cloud.o-forge.io/core/oc-lib/models/common/enum" "cloud.o-forge.io/core/oc-lib/models/common/enum"
"cloud.o-forge.io/core/oc-lib/models/resources/native_tools"
"cloud.o-forge.io/core/oc-lib/models/workflow_execution" "cloud.o-forge.io/core/oc-lib/models/workflow_execution"
"cloud.o-forge.io/core/oc-lib/tools" "cloud.o-forge.io/core/oc-lib/tools"
@@ -91,10 +92,10 @@ func (s *ScheduleManager) getExecution(from time.Time, to time.Time) (exec_list
} }
func (s *ScheduleManager) ExecuteWorkflow(resp tools.NATSResponse) { func (s *ScheduleManager) ExecuteWorkflow(resp tools.NATSResponse) {
var m map[string]string var event native_tools.WorkflowEventParams
json.Unmarshal(resp.Payload, &m) json.Unmarshal(resp.Payload, &event)
access := oclib.NewRequestAdmin(oclib.LibDataEnum(oclib.WORKFLOW), nil) access := oclib.NewRequestAdmin(oclib.LibDataEnum(oclib.WORKFLOW), nil)
if d := access.LoadOne(fmt.Sprintf("%v", m["workflow_id"])); d.Err == "" { if d := access.LoadOne(fmt.Sprintf("%v", event.WorkflowResourceID)); d.Err == "" {
eventExec := &workflow_execution.WorkflowExecution{ eventExec := &workflow_execution.WorkflowExecution{
WorkflowID: d.Data.GetID(), WorkflowID: d.Data.GetID(),
ExecDate: time.Now(), ExecDate: time.Now(),