(task task.Task)
| 113 | } |
| 114 | |
| 115 | func (dts *DefaultTaskScheduler) AddTask(task task.Task) error { |
| 116 | log.Printf("Register task [%v] at %v", task.ActionName, task.Schedule) |
| 117 | at := dts.cruds["task"].NewActiveTaskInstance(task) |
| 118 | dts.activeTasks = append(dts.activeTasks, at) |
| 119 | _, err := dts.cronService.AddJob(task.Schedule, at) |
| 120 | |
| 121 | return err |
| 122 | } |
| 123 | |
| 124 | func (dbResource *DbResource) NewActiveTaskInstance(task task.Task) *ActiveTaskInstance { |
| 125 | return &ActiveTaskInstance{ |
no test coverage detected