fix: add new logs to orchestrator and increase clock change polling to every 5 minutes

This commit is contained in:
Gareth George
2024-03-23 18:58:33 +00:00
parent ac7f24ed04
commit 5b7e2b080d
2 changed files with 2 additions and 7 deletions
+1 -6
View File
@@ -251,12 +251,7 @@ func (o *Orchestrator) Run(mainCtx context.Context) {
cb(err)
}
if nextTime := t.task.Next(o.curTime()); nextTime != nil {
o.taskQueue.Push(scheduledTask{
task: t.task,
runAt: *nextTime,
})
}
o.ScheduleTask(t.task, t.priority)
}
}
+1 -1
View File
@@ -7,7 +7,7 @@ import (
"time"
)
var taskQueueDefaultPollInterval = 15 * time.Minute
var taskQueueDefaultPollInterval = 3 * time.Minute
type taskQueue struct {
dequeueMu sync.Mutex