@@ -159,13 +159,13 @@ def refresh_registry(self):
159
159
Explicitly calling this method allows for direct control of the state of the registry cache. Every time this
160
160
method is called the complete registry state will be retrieved from the remote registry store backend
161
161
(e.g., GCS, S3), and the cache timer will be reset. If refresh_registry() is run before get_online_features()
162
- is called, then get_online_feature () will use the cached registry instead of retrieving (and caching) the
162
+ is called, then get_online_features () will use the cached registry instead of retrieving (and caching) the
163
163
registry itself.
164
164
165
165
Additionally, the TTL for the registry cache can be set to infinity (by setting it to 0), which means that
166
166
refresh_registry() will become the only way to update the cached registry. If the TTL is set to a value
167
167
greater than 0, then once the cache becomes stale (more time than the TTL has passed), a new cache will be
168
- downloaded synchronously, which may increase latencies if the triggering method is get_online_features()
168
+ downloaded synchronously, which may increase latencies if the triggering method is get_online_features().
169
169
"""
170
170
registry_config = self .config .get_registry_config ()
171
171
registry = Registry (registry_config , repo_path = self .repo_path )
@@ -488,13 +488,10 @@ def _plan(
488
488
489
489
The plan method dry-runs registering one or more definitions (e.g., Entity, FeatureView), and produces
490
490
a list of all the changes the that would be introduced in the feature repo. The changes computed by the plan
491
- command are for informational purpose , and are not actually applied to the registry.
491
+ command are for informational purposes , and are not actually applied to the registry.
492
492
493
493
Args:
494
- objects: A single object, or a list of objects that are intended to be registered with the Feature Store.
495
- objects_to_delete: A list of objects to be deleted from the registry.
496
- partial: If True, apply will only handle the specified objects; if False, apply will also delete
497
- all the objects in objects_to_delete.
494
+ desired_repo_contents: The desired repo state.
498
495
499
496
Raises:
500
497
ValueError: The 'objects' parameter could not be parsed properly.
@@ -1203,8 +1200,7 @@ def get_online_features(
1203
1200
Exception: No entity with the specified name exists.
1204
1201
1205
1202
Examples:
1206
- Materialize all features into the online store over the interval
1207
- from 3 hours ago to 10 minutes ago, and then retrieve these online features.
1203
+ Retrieve online features from an online store.
1208
1204
1209
1205
>>> from feast import FeatureStore, RepoConfig
1210
1206
>>> fs = FeatureStore(repo_path="feature_repo")
@@ -1580,7 +1576,7 @@ def _read_from_online_store(
1580
1576
) -> List [Tuple [List [Timestamp ], List ["FieldStatus.ValueType" ], List [Value ]]]:
1581
1577
""" Read and process data from the OnlineStore for a given FeatureView.
1582
1578
1583
- This method guarentees that the order of the data in each element of the
1579
+ This method guarantees that the order of the data in each element of the
1584
1580
List returned is the same as the order of `requested_features`.
1585
1581
1586
1582
This method assumes that `provider.online_read` returns data for each
@@ -1642,7 +1638,7 @@ def _populate_response_from_feature_data(
1642
1638
requested_features : Iterable [str ],
1643
1639
table : FeatureView ,
1644
1640
):
1645
- """ Populate the GetOnlineFeaturesReponse with feature data.
1641
+ """ Populate the GetOnlineFeaturesResponse with feature data.
1646
1642
1647
1643
This method assumes that `_read_from_online_store` returns data for each
1648
1644
combination of Entities in `entity_rows` in the same order as they
@@ -1707,7 +1703,6 @@ def _augment_response_with_on_demand_transforms(
1707
1703
full_feature_names: A boolean that provides the option to add the feature view prefixes to the feature names,
1708
1704
changing them from the format "feature" to "feature_view__feature" (e.g., "daily_transactions" changes to
1709
1705
"customer_fv__daily_transactions").
1710
- result_rows: List of result rows to be augmented with on demand feature values.
1711
1706
"""
1712
1707
requested_odfv_map = {
1713
1708
odfv .name : odfv for odfv in requested_on_demand_feature_views
0 commit comments