logger.Debugf("interval is %v, not running worker", interval)
return
}
- if !locker.Lock(ctx, h.db) {
+ if !locker.Lock(ctx, h.dbConnector.GetDB) {
// context canceled
return
}
func (h *Handler) containerLogSweepWorker() {
h.periodicWorker("container log sweep", h.Cluster.Containers.Logging.SweepInterval.Duration(), dblock.ContainerLogSweep, func(ctx context.Context) error {
- db, err := h.db(ctx)
+ db, err := h.dbConnector.GetDB(ctx)
if err != nil {
return err
}