fix: Refreshes the registry instead of stopping the background refresh (

#89) * fix: Refreshes the registry instead of stopping the background refresh --------- Co-authored-by: Bhargav Dodla <[email protected]>
ExpediaGroup · Mar 7, 2024 · c540117 · c540117
1 parent 6a0d07d
commit c540117
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/go/internal/feast/registry/registry.go b/go/internal/feast/registry/registry.go
@@ -87,7 +87,6 @@ func (r *Registry) RefreshRegistryOnInterval() {
 		err := r.refresh()
 		if err != nil {
 			log.Error().Stack().Err(err).Msg("Registry refresh Failed")
-			return
 		}
 	}
 }
@@ -104,7 +103,7 @@ func (r *Registry) getRegistryProto() (*core.Registry, error) {
 	}
 	registryProto, err := r.registryStore.GetRegistryProto()
 	if err != nil {
-		return registryProto, err
+		return nil, err
 	}
 	r.load(registryProto)
 	return registryProto, nil