(ctx context.Context)
| 231 | } |
| 232 | |
| 233 | func (task *TriggerTask) Run(ctx context.Context) { |
| 234 | task.triggerContextMu.Lock() |
| 235 | |
| 236 | executionTime := time.Now() |
| 237 | task.task(ctx) |
| 238 | completionTime := time.Now() |
| 239 | |
| 240 | task.triggerContext.Update(completionTime, executionTime, task.nextTriggerTime) |
| 241 | task.triggerContextMu.Unlock() |
| 242 | |
| 243 | if !task.IsCancelled() { |
| 244 | task.Schedule() |
| 245 | } |
| 246 | } |
nothing calls this directly
no test coverage detected