Skip to content

feat: Added batching to feature server /push to offline store (#5683) #5729

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 7 commits into from
Jan 3, 2026
Merged

feat: Added batching to feature server /push to offline store (#5683) #5729

Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
1a3ccbd
feat: added batching to feature server /push to offline store (#5683)
jfw-ppi Nov 18, 2025
49de0cb
Merge branch 'master' into 5683-configurable-batching-feature-server-…
jfw-ppi Dec 18, 2025
fbcc467
Merge branch 'master' into 5683-configurable-batching-feature-server-…
jfw-ppi Dec 28, 2025
bb299d9
Merge branch 'master' into 5683-configurable-batching-feature-server-…
jfw-ppi Dec 28, 2025
2747405
feat: added batching to feature server /push to offline store ([#5683…
jfw-ppi Jan 1, 2026
02899c1
Merge branch 'master' into 5683-configurable-batching-feature-server-…
jfw-ppi Jan 1, 2026
a65937a
Merge branch 'master' into 5683-configurable-batching-feature-server-…
jfw-ppi Jan 2, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Merge branch 'master' into 5683-configurable-batching-feature-server-… 
…push

Signed-off-by: Jacob Weinhold <29459386+jfw-ppi@users.noreply.github.com>
  • Loading branch information
@jfw-ppi
jfw-ppi committed Dec 28, 2025
commit bb299d952857f867719be7126de6fa22c184ad8c
2 changes: 2 additions & 0 deletions sdk/python/tests/unit/test_feature_server.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -224,6 +224,7 @@ def test_materialize_request_model():
assert req2.start_ts == "2021-01-01T00:00:00"
assert req2.end_ts == "2021-01-02T00:00:00"


def _enable_offline_batching_config(
fs, enabled: bool = True, batch_size: int = 1, batch_interval_seconds: int = 60
):
Expand Down Expand Up @@ -461,6 +462,7 @@ def test_offline_batcher_interval_flush(mock_fs_factory):
assert kwargs["to"] == PushMode.OFFLINE
assert len(kwargs["df"]) == 2


# Static Artifacts Tests
@pytest.fixture
def mock_store_with_static_artifacts(tmp_path):
Expand Down
Loading