test

Signed-off-by: Kevin Su <[email protected]>
flyteorg · Sep 25, 2023 · 9910612 · 9910612
1 parent d3e61ed
commit 9910612
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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)