Skip to content

Commit

Permalink
fixup! Reuse same setup and assertion
Browse files Browse the repository at this point in the history
  • Loading branch information
breno-costa committed May 15, 2024
1 parent c5779b7 commit 24068d5
Showing 1 changed file with 5 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -402,7 +402,9 @@ def test_online_retrieval_with_shared_batch_source(environment, universal_data_s
)


def setup_feature_store_universal_feature_views(environment, universal_data_sources) -> FeatureStore:
def setup_feature_store_universal_feature_views(
environment, universal_data_sources
) -> FeatureStore:
fs: FeatureStore = environment.feature_store
entities, datasets, data_sources = universal_data_sources
feature_views = construct_universal_feature_views(data_sources)
Expand Down Expand Up @@ -459,7 +461,7 @@ def assert_feature_store_universal_feature_views_response(df: pd.DataFrame):
def test_online_retrieval_with_event_timestamps(
environment, universal_data_sources, full_feature_names
):
fs = setup_feature_store_universal_feature_views(fs, universal_data_sources)
fs = setup_feature_store_universal_feature_views(universal_data_sources)

response = fs.get_online_features(
features=[
Expand All @@ -479,7 +481,7 @@ def test_online_retrieval_with_event_timestamps(
def test_async_online_retrieval_with_event_timestamps(
environment, universal_data_sources
):
fs = setup_feature_store_universal_feature_views(fs, universal_data_sources)
fs = setup_feature_store_universal_feature_views(universal_data_sources)

response = asyncio.run(
fs.get_online_features_async(
Expand Down

0 comments on commit 24068d5

Please sign in to comment.