diff --git a/sdk/python/feast/infra/passthrough_provider.py b/sdk/python/feast/infra/passthrough_provider.py index 9482b808a9b..ca344c6eec7 100644 --- a/sdk/python/feast/infra/passthrough_provider.py +++ b/sdk/python/feast/infra/passthrough_provider.py @@ -148,10 +148,16 @@ def update_infra( ): # Call update only if there is an online store if self.online_store: + tables_to_keep_online = [ + fv + for fv in tables_to_keep + if not hasattr(fv, "online") or (hasattr(fv, "online") and fv.online) + ] + self.online_store.update( config=self.repo_config, tables_to_delete=tables_to_delete, - tables_to_keep=tables_to_keep, + tables_to_keep=tables_to_keep_online, entities_to_keep=entities_to_keep, entities_to_delete=entities_to_delete, partial=partial,