fix status cache

pluralsh · Jul 5, 2024 · 318f9ac · 318f9ac
1 parent 3e52525
commit 318f9ac
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/applier/builder.go b/pkg/applier/builder.go
@@ -85,7 +85,7 @@ func (cb *commonBuilder) finalize() (*commonBuilder, error) {
 	}
 	if cx.statusWatcher == nil {
 		cx.statusWatcher = watcher.NewDynamicStatusWatcher(cx.client, cx.mapper, watcher.Options{
-			RESTScopeStrategy:     lo.ToPtr(kwatcher.RESTScopeRoot),
+			RESTScopeStrategy: lo.ToPtr(kwatcher.RESTScopeRoot),
 			Filters: &kwatcher.Filters{
 				Labels: common.ManagedByAgentLabelSelector(),
 				Fields: nil,

diff --git a/pkg/cache/resource_cache.go b/pkg/cache/resource_cache.go
@@ -200,7 +200,7 @@ func (in *ResourceCache) deleteCacheEntry(r *event.ResourceStatus) {
 
 func (in *ResourceCache) GetCacheStatus(key string) (*applyevent.StatusEvent, error) {
 	entry, exists := in.cache.Get(key)
-	if exists {
+	if exists && entry.status != nil {
 		return entry.status, nil
 	}
 	rk, err := ResourceKeyFromString(key)