MCPcopy
hub / github.com/feast-dev/feast / plan

Method plan

sdk/python/feast/infra/online_stores/sqlite.py:317–348  ·  view source on GitHub ↗
(
        self, config: RepoConfig, desired_registry_proto: RegistryProto
    )

Source from the content-addressed store, hash-verified

315 )
316
317 def plan(
318 self, config: RepoConfig, desired_registry_proto: RegistryProto
319 ) -> List[InfraObject]:
320 project = config.project
321 versioning = config.registry.enable_online_feature_view_versioning
322
323 infra_objects: List[InfraObject] = [
324 SqliteTable(
325 path=self._get_db_path(config),
326 name=_table_id(
327 project,
328 FeatureView.from_proto(view),
329 versioning,
330 ),
331 )
332 for view in [
333 *desired_registry_proto.feature_views,
334 *desired_registry_proto.stream_feature_views,
335 ]
336 ]
337
338 for lv_proto in desired_registry_proto.label_views:
339 if lv_proto.spec.online:
340 lv = LabelView.from_proto(lv_proto)
341 infra_objects.append(
342 SqliteTable(
343 path=self._get_db_path(config),
344 name=_table_id(project, lv, versioning),
345 )
346 )
347
348 return infra_objects
349
350 def teardown(
351 self,

Callers

nothing calls this directly

Calls 4

_get_db_pathMethod · 0.95
SqliteTableClass · 0.85
_table_idFunction · 0.70
from_protoMethod · 0.45

Tested by

no test coverage detected