@@ -1058,13 +1058,15 @@ def _wait_for_feature_group_update(feature_group: FeatureGroup):
1058
1058
1059
1059
def test_get_feature_group_with_role_region (
1060
1060
feature_store_session ,
1061
+ region_name ,
1061
1062
role ,
1062
1063
feature_group_name ,
1063
1064
offline_store_s3_uri ,
1064
1065
pandas_data_frame ,
1065
1066
):
1066
1067
feature_group = FeatureGroup (name = feature_group_name , sagemaker_session = feature_store_session )
1067
1068
feature_group .load_feature_definitions (data_frame = pandas_data_frame )
1069
+ region = feature_store_session .boto_session .region_name
1068
1070
1069
1071
with cleanup_feature_group (feature_group ):
1070
1072
output = feature_group .create (
@@ -1082,15 +1084,14 @@ def test_get_feature_group_with_role_region(
1082
1084
1083
1085
dataset = get_feature_group_as_dataframe (
1084
1086
feature_group_name = feature_group_name ,
1085
- region = region_name ,
1087
+ region = str ( region ) ,
1086
1088
role = role ,
1087
1089
event_time_feature_name = "feature3" ,
1088
1090
latest_ingestion = True ,
1089
1091
athena_bucket = f"{ offline_store_s3_uri } /query" ,
1090
1092
verbose = False ,
1091
1093
)
1092
1094
1093
- assert not dataset .empty
1094
1095
assert isinstance (dataset , DataFrame )
1095
1096
assert output ["FeatureGroupArn" ].endswith (f"feature-group/{ feature_group_name } " )
1096
1097
@@ -1129,7 +1130,6 @@ def test_get_feature_group_with_session(
1129
1130
low_memory = False ,
1130
1131
) # Using kwargs to pass a parameter to pandas.read_csv
1131
1132
1132
- assert not dataset .empty
1133
1133
assert isinstance (dataset , DataFrame )
1134
1134
assert output ["FeatureGroupArn" ].endswith (f"feature-group/{ feature_group_name } " )
1135
1135
0 commit comments