Move ctxWithTimeout into updateCache

Co-authored-by: Jordan Krage <jmank88@gmail.com>
smartcontractkit · Apr 1, 2024 · fedd223 · fedd223
1 parent d0ae2a1
commit fedd223
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/services/ocrcommon/data_source.go b/core/services/ocrcommon/data_source.go
@@ -255,9 +255,9 @@ func (ds *inMemoryDataSourceCache) Close() error {
 // updater periodically updates data source cache.
 func (ds *inMemoryDataSourceCache) updater() {
 	ticker := time.NewTicker(ds.cacheFreshness)
-	ctx, cancel := ds.chStop.CtxCancel(context.WithTimeout(context.Background(), time.Second*10))
-	defer cancel()
 	updateCache := func() {
+		ctx, cancel := ds.chStop.CtxCancel(context.WithTimeout(context.Background(), time.Second*10))
+		defer cancel()
 		if err := ds.updateCache(ctx); err != nil {
 			ds.lggr.Warnf("failed to update cache, err: %v", err)
 		}