FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

fix: Disable materialized odfvs for historical retrieval by astronautas · Pull Request #5880 · feast-dev/feast · GitHub

/ feast Public

fix: Disable materialized odfvs for historical retrieval #5880

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
franciscojavierarceo merged 2 commits into from
Jan 26, 2026
Conversation 22 Commits 2 Checks 17 Files changed
Merged

fix: Disable materialized odfvs for historical retrieval #5880

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
44e8076
Disable ODFVs for offline retrieval
astronautas Jan 22, 2026
d1a3564
Merge branch 'master' into fix/disable-materialized-odfvs-for-histori…
astronautas Jan 26, 2026
File filter

Filter by extension

Filter by extension .py  (1) .toml  (1) No extension  (1) All 3 file types selected
Only manifest files
Viewed files
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Unified
Split
Hide whitespace
Diff view
Unified
Split
Hide whitespace
11 changes: 11 additions & 0 deletions Makefile
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -210,6 +210,17 @@ test-python-universal-spark: ## Run Python Spark integration tests
not test_snowflake" \
sdk/python/tests

test-python-historical-retrieval:
Comment thread
astronautas marked this conversation as resolved.

franciscojavierarceo Jan 26, 2026

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Choose a reason Spam Abuse Off Topic Outdated Duplicate Resolved Low Quality

nice!
## Run Python historical retrieval integration tests
PYTHONPATH='.' \
FULL_REPO_CONFIGS_MODULE=sdk.python.feast.infra.offline_stores.contrib.spark_repo_configuration \
PYTEST_PLUGINS=feast.infra.offline_stores.contrib.spark_offline_store.tests \
python -m pytest -n 8 --integration \
-k "test_historical_retrieval_with_validation or \
test_historical_features_persisting or \
test_historical_retrieval_fails_on_validation" \
sdk/python/tests

test-python-universal-trino: ## Run Python Trino integration tests
PYTHONPATH='.' \
FULL_REPO_CONFIGS_MODULE=sdk.python.feast.infra.offline_stores.contrib.trino_repo_configuration \
Expand Down
5 changes: 5 additions & 0 deletions pyproject.toml
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -264,3 +264,8 @@ exclude = [
".pyi",
"protos",
"sdk/python/feast/embedded_go/lib"]

[dependency-groups]
dev = [
"pytest-xdist>=3.8.0",
Comment thread
astronautas marked this conversation as resolved.
]
12 changes: 12 additions & 0 deletions sdk/python/feast/feature_store.py
Show comments
View file
Open in desktop
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode characters
Show hidden characters
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
# See the License for the specific language governing permissions and
# limitations under the License.
import asyncio
import copy
import itertools
import os
import warnings
Expand Down Expand Up @@ -1233,6 +1234,17 @@ def get_historical_features(
# TODO(achal): _group_feature_refs returns the on demand feature views, but it's not passed into the provider.
# This is a weird interface quirk - we should revisit the `get_historical_features` to
# pass in the on demand feature views as well.

Comment thread
astronautas marked this conversation as resolved.
# Deliberately disable writing to online store for ODFVs during historical retrieval
# since it's not applicable in this context.
# This does not change the output, since it forces to recompute ODFVs on historical retrieval
# but that is fine, since ODFVs precompute does not to work for historical retrieval (as per docs), only for online retrieval
# Copy to avoid side effects outside of this method
all_on_demand_feature_views = copy.deepcopy(all_on_demand_feature_views)

for odfv in all_on_demand_feature_views:
odfv.write_to_online_store = False
Comment thread
astronautas marked this conversation as resolved.
Comment thread
astronautas marked this conversation as resolved.

fvs, odfvs = utils._group_feature_refs(
_feature_refs,
all_feature_views,
Expand Down
Loading
Back | FazBrowse Home | New Git URL