File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -142,8 +142,7 @@ def create_table_ddl():
142
142
" STORED AS\n "
143
143
" INPUTFORMAT 'parquet.hive.DeprecatedParquetInputFormat'\n "
144
144
" OUTPUTFORMAT 'parquet.hive.DeprecatedParquetOutputFormat'\n "
145
- "LOCATION 's3://sagemaker-test-featurestore-{region}-{account}"
146
- "/{account}/sagemaker/us-east-2/offline-store/{feature_group_name}'"
145
+ "LOCATION '{resolved_output_s3_uri}'"
147
146
)
148
147
149
148
@@ -180,7 +179,8 @@ def test_create_feature_store(
180
179
):
181
180
feature_group = FeatureGroup (name = feature_group_name , sagemaker_session = feature_store_session )
182
181
feature_group .load_feature_definitions (data_frame = pandas_data_frame )
183
-
182
+ resolved_output_s3_uri = feature_group .describe ().get ("OfflineStoreConfig" ).get ("S3StorageConfig" ).get ("ResolvedOutputS3Uri" )
183
+
184
184
with cleanup_feature_group (feature_group ):
185
185
output = feature_group .create (
186
186
s3_uri = offline_store_s3_uri ,
@@ -225,6 +225,7 @@ def test_create_feature_store(
225
225
feature_group_name = feature_group_name ,
226
226
region = feature_store_session .boto_session .region_name ,
227
227
account = feature_store_session .account_id (),
228
+ resolved_output_s3_uri = resolved_output_s3_uri
228
229
)
229
230
== feature_group .as_hive_ddl ()
230
231
)
You can’t perform that action at this time.
0 commit comments