(
self, config: RepoConfig, desired_registry_proto: RegistryProto
)
| 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, |
nothing calls this directly
no test coverage detected