diff --git a/cache/auto_refresh.go b/cache/auto_refresh.go index ef3ffb3..7f058e8 100644 --- a/cache/auto_refresh.go +++ b/cache/auto_refresh.go @@ -235,7 +235,7 @@ func (w *autoRefresh) enqueueBatches(ctx context.Context) error { for _, batch := range batches { for _, b := range batch { - logger.Debugf(ctx, "Enqueuing batch with id: %v", b.GetID()) + logger.Infof(ctx, "Enqueuing batch with id: %v", b.GetID()) w.workqueue.Add(b.GetID()) } } @@ -277,10 +277,12 @@ func (w *autoRefresh) sync(ctx context.Context) (err error) { default: itemID, shutdown := w.workqueue.Get() if shutdown { + logger.Infof(ctx, "Shutting down worker") return nil } t := w.metrics.SyncLatency.Start() + logger.Infof(ctx, "Syncing item with id [%v]", itemID) item, ok := w.lruMap.Get(itemID) if !ok { logger.Debugf(ctx, "item with id [%v] not found in cache", itemID)