FeatureStore.get_online_features() throws FeatureViewNotFoundException #5606

for project in feature_store.list_projects():
    print(project)
-----
{
  "spec": {
    "name": "customer_credit_risk",
    "description": "A project for customer credit risk"
  },
  "meta": {
    "createdTimestamp": "2025-09-10T02:36:27.540674Z",
    "lastUpdatedTimestamp": "2025-09-10T07:19:22.520531Z"
  }
}

for fv in feature_store.list_feature_views():
    print(f"FeatureView: {fv.name}")
    for feature in fv.features:
        print(f"  Feature: {feature.name} ({feature.dtype})")
-----
FeatureView: customer_credit_risk_feature_view
  Feature: purpose_business (Float32)
  Feature: purpose_car (Float32)
  Feature: purpose_domestic_appliances (Float32)
...

timestamp = training_df['event_timestamp'][0].to_pydatetime()
feature_store.materialize(
    start_date=datetime.strptime("2025-09-10T00:00:00", "%Y-%m-%dT%H:%M:%S"),
    end_date=datetime.now()
)
---
Materializing 1 feature views from 2025-09-10 00:00:00+00:00 to 2025-09-10 17:29:35+00:00 into the sqlite online store.

feature_vector = feature_store.get_online_features(
    features=[
        'customer_credit_risk_customer_credit_risk_feature_view:purpose_business'
    ],
    #features=customer_credit_risk_features,
    entity_rows=[{
            "entity_id": 0,
    }]
).to_df()

---------------------------------------------------------------------------
FeatureViewNotFoundException              Traceback (most recent call last)
Cell In[80], line 1
----> 1 feature_vector = feature_store.get_online_features(
      2     features=[
      3         'customer_credit_risk_customer_credit_risk_feature_view:purpose_business'
      4     ],
      5     #features=customer_credit_risk_features,
      6     entity_rows=[
      7         {
      8             "entity_id": 0,
      9         }
     10     ]
     11 ).to_df()

File ~/venv/feast/lib/python3.11/site-packages/feast/feature_store.py:2080, in FeatureStore.get_online_features(self, features, entity_rows, full_feature_names)
   2037 """
   2038 Retrieves the latest online feature data.
   2039 
   (...)   2076     >>> online_response_dict = online_response.to_dict()
   2077 """
   2078 provider = self._get_provider()
-> 2080 return provider.get_online_features(
   2081     config=self.config,
   2082     features=features,
   2083     entity_rows=entity_rows,
   2084     registry=self._registry,
   2085     project=self.project,
   2086     full_feature_names=full_feature_names,
   2087 )

File ~/venv/feast/lib/python3.11/site-packages/feast/infra/passthrough_provider.py:251, in PassthroughProvider.get_online_features(self, config, features, entity_rows, registry, project, full_feature_names)
    239 def get_online_features(
    240     self,
    241     config: RepoConfig,
   (...)    249     full_feature_names: bool = False,
    250 ) -> OnlineResponse:
--> 251     return self.online_store.get_online_features(
    252         config=config,
    253         features=features,
    254         entity_rows=entity_rows,
    255         registry=registry,
    256         project=project,
    257         full_feature_names=full_feature_names,
    258     )

File ~/venv/feast/lib/python3.11/site-packages/feast/infra/online_stores/online_store.py:179, in OnlineStore.get_online_features(self, config, features, entity_rows, registry, project, full_feature_names)
    165                 raise ValueError(
    166                     "All entity_rows must have the same keys."
    167                 ) from e
    169     entity_rows = columnar
    171 (
    172     join_key_values,
    173     grouped_refs,
    174     entity_name_to_join_key_map,
    175     requested_on_demand_feature_views,
    176     feature_refs,
    177     requested_result_row_names,
    178     online_features_response,
--> 179 ) = utils._prepare_entities_to_read_from_online_store(
    180     registry=registry,
    181     project=project,
    182     features=features,
    183     entity_values=entity_rows,
    184     full_feature_names=full_feature_names,
    185     native_entity_values=True,
    186 )
    188 for table, requested_features in grouped_refs:
    189     # Get the correct set of entity values with the correct join keys.
    190     table_entity_values, idxs, output_len = utils._get_unique_entities(
    191         table,
    192         join_key_values,
    193         entity_name_to_join_key_map,
    194     )

File ~/venv/feast/lib/python3.11/site-packages/feast/utils.py:1204, in _prepare_entities_to_read_from_online_store(registry, project, features, entity_values, full_feature_names, native_entity_values)
   1182 def _prepare_entities_to_read_from_online_store(
   1183     registry,
   1184     project,
   (...)   1190     native_entity_values: bool = True,
   1191 ):
   1192     from feast.feature_view import DUMMY_ENTITY, DUMMY_ENTITY_ID, DUMMY_ENTITY_VAL
   1194     (
   1195         feature_refs,
   1196         requested_on_demand_feature_views,
   1197         entity_name_to_join_key_map,
   1198         entity_type_map,
   1199         join_keys_set,
   1200         grouped_refs,
   1201         requested_result_row_names,
   1202         needed_request_data,
   1203         entityless_case,
-> 1204     ) = _get_online_request_context(registry, project, features, full_feature_names)
   1206     # Extract Sequence from RepeatedValue Protobuf.
   1207     entity_value_lists: Dict[str, Union[List[Any], List[ValueProto]]] = {
   1208         k: list(v) if isinstance(v, Sequence) else list(v.val)
   1209         for k, v in entity_values.items()
   1210     }

File ~/venv/feast/lib/python3.11/site-packages/feast/utils.py:1127, in _get_online_request_context(registry, project, features, full_feature_names)
   1120 from feast.feature_view import DUMMY_ENTITY_NAME
   1122 _feature_refs = _get_features(registry, project, features, allow_cache=True)
   1124 (
   1125     requested_feature_views,
   1126     requested_on_demand_feature_views,
-> 1127 ) = _get_feature_views_to_use(
   1128     registry=registry,
   1129     project=project,
   1130     features=features,
   1131     allow_cache=True,
   1132     hide_dummy_entity=False,
   1133 )
   1135 (
   1136     entity_name_to_join_key_map,
   1137     entity_type_map,
   1138     join_keys_set,
   1139 ) = _get_entity_maps(registry, project, requested_feature_views)
   1141 _validate_feature_refs(_feature_refs, full_feature_names)

File ~/venv/feast/lib/python3.11/site-packages/feast/utils.py:1075, in _get_feature_views_to_use(registry, project, features, allow_cache, hide_dummy_entity)
   1073 fvs_to_use, od_fvs_to_use = [], []
   1074 for name, projection in feature_views:
-> 1075     fv = registry.get_any_feature_view(name, project, allow_cache)
   1077     if isinstance(fv, OnDemandFeatureView):
   1078         od_fvs_to_use.append(
   1079             fv.with_projection(copy.copy(projection)) if projection else fv
   1080         )

File ~/venv/feast/lib/python3.11/site-packages/feast/infra/registry/caching_registry.py:117, in CachingRegistry.get_any_feature_view(self, name, project, allow_cache)
    115 if allow_cache:
    116     self._refresh_cached_registry_if_necessary()
--> 117     return proto_registry_utils.get_any_feature_view(
    118         self.cached_registry_proto, name, project
    119     )
    120 return self._get_any_feature_view(name, project)

File ~/venv/feast/lib/python3.11/site-packages/feast/infra/registry/proto_registry_utils.py:92, in registry_proto_cache_name.<locals>.wrapper(registry_proto, name, project)
     90     return cache[key]
     91 else:
---> 92     value = func(registry_proto, name, project)
     93     cache[key] = value
     94     return value

File ~/venv/feast/lib/python3.11/site-packages/feast/infra/registry/proto_registry_utils.py:147, in get_any_feature_view(registry_proto, name, project)
    141     if (
    142         on_demand_feature_view.spec.project == project
    143         and on_demand_feature_view.spec.name == name
    144     ):
    145         return OnDemandFeatureView.from_proto(on_demand_feature_view)
--> 147 raise FeatureViewNotFoundException(name, project)

FeatureViewNotFoundException: Feature view customer_credit_risk_customer_credit_risk_feature_view does not exist in project customer_credit_risk

project: customer_credit_risk
registry:
    registry_type: sql
    path: postgresql+psycopg2://postgres@localhost:5432/feast_registry
    cache_ttl_seconds: 60

provider: local
offline_store:
  type: postgres
  host: localhost
  port: 5432
  database: offline_features
  db_schema: credit
  user: dbadm
  password: ****
online_store:
  type: sqlite
  path: data/online_store.db

entity_key_serialization_version: 3
auth:
  type: no_auth

feature_store_config = read_yaml(f"{FEATURE_REPO_DIR}/feature_store.yaml")

repo_config = RepoConfig(
    registry=SqlRegistryConfig(
        path="postgresql+psycopg2://postgres@localhost:5432/feast_registry", 
        registry_type="sql",
        sqlalchemy_config_kwargs={
            "echo": False,
            "pool_pre_ping": True,
        }
    ),
    project="customer_credit_risk",
    provider="local",
    offline_store=PostgreSQLOfflineStoreConfig(**feature_store_config['offline_store']),
    online_store=SqliteOnlineStoreConfig(path=f'{FEATURE_REPO_DIR}/data/online_store.db')
)

"""Feature definition
"""
from datetime import timedelta

from feast import (
    Entity,
    FeatureService,
    FeatureView,
    Field,
    Project,
)
from feast.infra.offline_stores.contrib.postgres_offline_store.postgres_source import (
    PostgreSQLSource,
)

from feast.feature_logging import LoggingConfig
from feast.infra.offline_stores.file_source import FileLoggingDestination
from feast.types import Float32, Int64

from utility import (
    get_yaml_value
)


project = Project(
    name=feature_store_config['project'],
    description="A project for customer credit risk"
)

# https://docs.feast.dev/reference/data-sources/postgres
credit_risk_feature_source = PostgreSQLSource(
    name="customer_credit_risk_feature_source",
    query="SELECT * FROM credit.customer_credit_risk_features",
    timestamp_field="event_timestamp",
    created_timestamp_column="created",
)

customer = Entity(name="customer", join_keys=["entity_id"])

credit_risk_feature_view = FeatureView(
    name="customer_credit_risk_feature_view",
    entities=[customer],
    ttl=timedelta(minutes=1),
    # The list of features defined below act as a schema to both define features
    # for both materialization of features into a store, and are used as references
    # during retrieval for building a training dataset or serving features
    schema=[
        Field(name="purpose_business", dtype=Float32),
        Field(name="purpose_car", dtype=Float32),
        Field(name="purpose_domestic_appliances", dtype=Float32),
        Field(name="purpose_education", dtype=Float32),
        Field(name="purpose_furniture_equipment", dtype=Float32),
        Field(name="purpose_radio_tv", dtype=Float32),
        Field(name="purpose_repairs", dtype=Float32),
        Field(name="purpose_vacation_others", dtype=Float32),
        Field(name="gender_female", dtype=Float32),
        Field(name="gender_male", dtype=Float32),
        Field(name="property_free", dtype=Float32),
        Field(name="property_own", dtype=Float32),
        Field(name="property_rent", dtype=Float32),
        Field(name="savings_little", dtype=Float32),
        Field(name="savings_moderate", dtype=Float32),
        Field(name="savings_no_inf", dtype=Float32),
        Field(name="savings_quite_rich", dtype=Float32),
        Field(name="savings_rich", dtype=Float32),
        Field(name="check_little", dtype=Float32),
        Field(name="check_moderate", dtype=Float32),
        Field(name="check_no_inf", dtype=Float32),
        Field(name="check_rich", dtype=Float32),
        Field(name="generation_student", dtype=Float32),
        Field(name="generation_young", dtype=Float32),
        Field(name="generation_adult", dtype=Float32),
        Field(name="generation_senior", dtype=Float32),
        Field(name="job_0", dtype=Float32),
        Field(name="job_1", dtype=Float32),
        Field(name="job_2", dtype=Float32),
        Field(name="job_3", dtype=Float32),
        Field(name="amount_0", dtype=Float32),
        Field(name="amount_1", dtype=Float32),
        Field(name="amount_2", dtype=Float32),
        Field(name="amount_3", dtype=Float32),
        # Field(name="avg_daily_trips", dtype=Int64, description="Average daily trips"),
    ],
    source=credit_risk_feature_source,             # Link to the raw data storage technology
    online=True,                                    # Tell FEAST to materialise into online store.
)

customer_credit_risk_features = FeatureService(
    name="customer_credit_risk_feature_service",
    description="Features for Customer Credit Dirk Model",
    tags={
        "version": "0.1"
    },
    features=[
        credit_risk_feature_view,
    ],
    logging_config=LoggingConfig(
        destination=FileLoggingDestination(path="data")
    ),
)

feature_store.apply(
    objects=[
        project,
        customer,
        credit_risk_feature_source,
        credit_risk_feature_view,
        customer_credit_risk_features
    ]
)