Skip to content

Commit c961d31

Browse files
authored
Fix failing historical retrieval assertion (#1622)
* Fix failing historical retrieval assertion Signed-off-by: Willem Pienaar <git@willem.co> * Ensure comments are accurate Signed-off-by: Willem Pienaar <git@willem.co>
1 parent 408a823 commit c961d31

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

sdk/python/tests/test_historical_retrieval.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -465,12 +465,13 @@ def test_historical_features_from_bigquery_sources(
465465
],
466466
)
467467

468+
# Make sure that custom dataset name is being used from the offline_store config
468469
if provider_type == "gcp_custom_offline_config":
469-
# Make sure that custom dataset name is being used from the offline_store config
470470
assertpy.assert_that(job_from_df.query).contains("foo.entity_df")
471471
else:
472-
# If the custom dataset name isn't provided in the config, use default `feast` name
473-
assertpy.assert_that(job_from_df.query).contains("feast.entity_df")
472+
assertpy.assert_that(job_from_df.query).contains(
473+
f"{bigquery_dataset}.entity_df"
474+
)
474475

475476
actual_df_from_df_entities = job_from_df.to_df()
476477

0 commit comments

Comments
 (0)