From 9910612c9ede3bef42e8a0362e63b0b6858acb29 Mon Sep 17 00:00:00 2001 From: Kevin Su Date: Mon, 25 Sep 2023 16:33:04 -0700 Subject: [PATCH] test Signed-off-by: Kevin Su --- cache/auto_refresh.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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)