Update agent/cache/cache.go

Co-authored-by: Chris S. Kim <ckim@hashicorp.com>
hashicorp · Apr 19, 2022 · 0d1e0cc · 0d1e0cc
1 parent e8b691e
commit 0d1e0cc
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/agent/cache/cache.go b/agent/cache/cache.go
@@ -557,7 +557,8 @@ func (c *Cache) fetch(key string, r getOptions, allowNew bool, attempt uint, ign
 	// If we already have an entry, it is actively fetching, and we don't need
 	// to revalidate the cache, then return the currently active waiter.
 	if ok && entry.Fetching {
-		// If we need to revalidate, return immediately
+		// If we need to revalidate, return with a closed channel
+		// so the caller will immediately retry the cache
 		if r.Info.MustRevalidate {
 			ch := make(chan struct{})
 			close(ch)