diff --git a/sdk/python/feast/infra/registry/registry.py b/sdk/python/feast/infra/registry/registry.py index d2cf6a54ec..6f571a13b0 100644 --- a/sdk/python/feast/infra/registry/registry.py +++ b/sdk/python/feast/infra/registry/registry.py @@ -884,4 +884,7 @@ def _existing_feature_view_names_to_fvs(self) -> Dict[str, Message]: request_fvs = { fv.spec.name: fv for fv in self.cached_registry_proto.request_feature_views } - return {**odfvs, **fvs, **request_fvs} + sfv = { + fv.spec.name: fv for fv in self.cached_registry_proto.stream_feature_views + } + return {**odfvs, **fvs, **request_fvs, **sfv}