}
func (sch *Scheduler) updateMetrics() {
- earliest := time.Now()
+ earliest := time.Time{}
entries, _ := sch.queue.Entries()
running := sch.pool.Running()
for _, ent := range entries {
// ContainerStateLocked and running on a worker, most likely loading the
// payload image
if _, ok := running[ent.Container.UUID]; !ok {
- if ent.Container.CreatedAt.Before(earliest) {
+ if ent.Container.CreatedAt.Before(earliest) || earliest.IsZero() {
earliest = ent.Container.CreatedAt
}
}