From bbfb6d069b504cec29e1e68e9ef7abf777bb1495 Mon Sep 17 00:00:00 2001 From: Paul Dittamo Date: Fri, 24 May 2024 12:54:37 -0700 Subject: [PATCH] update processing grace period to 5 sync periods Signed-off-by: Paul Dittamo --- flytestdlib/cache/auto_refresh.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flytestdlib/cache/auto_refresh.go b/flytestdlib/cache/auto_refresh.go index 4499ad125d..bb23ef9369 100644 --- a/flytestdlib/cache/auto_refresh.go +++ b/flytestdlib/cache/auto_refresh.go @@ -364,7 +364,7 @@ func (w *autoRefresh) inProcessing(key interface{}) bool { item, found := w.processing.Load(key) if found { // handle potential race conditions where the item is in processing but not in the workqueue - if timeItem, ok := item.(time.Time); ok && time.Since(timeItem) > (w.syncPeriod*10) { + if timeItem, ok := item.(time.Time); ok && time.Since(timeItem) > (w.syncPeriod*5) { w.processing.Delete(key) return false }