diff --git a/main.go b/main.go index 16b8a04..284a6e1 100644 --- a/main.go +++ b/main.go @@ -43,9 +43,9 @@ func main() { exe_mngr := daemons.ExecutionManager{} go tools.NewNATSCaller().ListenNats(map[tools.NATSMethod]func(tools.NATSResponse){ - tools.CREATE_EXECTUTION: sch_mngr.GetNextScheduledWorkflows, // TODO: unused for now... - tools.WORKFLOW_EVENT: sch_mngr.ExecuteWorkflow, - tools.REMOVE_EXECUTION: daemons.Executions.DeleteSchedules, // TODO: unused for now... + tools.CREATE_EXECUTION: sch_mngr.GetNextScheduledWorkflows, // TODO: unused for now... + tools.WORKFLOW_EVENT: sch_mngr.ExecuteWorkflow, + tools.REMOVE_EXECUTION: daemons.Executions.DeleteSchedules, // TODO: unused for now... }) go sch_mngr.SchedulePolling() exe_mngr.RetrieveNextExecutions()