@@ -402,7 +402,9 @@ def test_online_retrieval_with_shared_batch_source(environment, universal_data_s
402402 )
403403
404404
405- def setup_feature_store_universal_feature_views (environment , universal_data_sources ) -> FeatureStore :
405+ def setup_feature_store_universal_feature_views (
406+ environment , universal_data_sources
407+ ) -> FeatureStore :
406408 fs : FeatureStore = environment .feature_store
407409 entities , datasets , data_sources = universal_data_sources
408410 feature_views = construct_universal_feature_views (data_sources )
@@ -459,7 +461,7 @@ def assert_feature_store_universal_feature_views_response(df: pd.DataFrame):
459461def test_online_retrieval_with_event_timestamps (
460462 environment , universal_data_sources , full_feature_names
461463):
462- fs = setup_feature_store_universal_feature_views (fs , universal_data_sources )
464+ fs = setup_feature_store_universal_feature_views (universal_data_sources )
463465
464466 response = fs .get_online_features (
465467 features = [
@@ -479,7 +481,7 @@ def test_online_retrieval_with_event_timestamps(
479481def test_async_online_retrieval_with_event_timestamps (
480482 environment , universal_data_sources
481483):
482- fs = setup_feature_store_universal_feature_views (fs , universal_data_sources )
484+ fs = setup_feature_store_universal_feature_views (universal_data_sources )
483485
484486 response = asyncio .run (
485487 fs .get_online_features_async (
0 commit comments