Skip to content

Commit 85e1536

Browse files
Fix Formatting.
1 parent 7228b47 commit 85e1536

File tree

2 files changed

+17
-21
lines changed

2 files changed

+17
-21
lines changed

src/sagemaker/feature_store/feature_group.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -333,8 +333,7 @@ def _ingest_row(
333333
(
334334
FeatureValue(
335335
feature_name=data_frame.columns[index - 1],
336-
value_as_string_list
337-
=IngestionManagerPandas._covert_feature_value_to_string_list(
336+
value_as_string_list=IngestionManagerPandas._covert_feature_to_string_list(
338337
row[index]
339338
),
340339
)
@@ -419,7 +418,7 @@ def _feature_value_is_not_none(
419418
return feature_value
420419

421420
@staticmethod
422-
def _covert_feature_value_to_string_list(feature_value: List[Any]):
421+
def _covert_feature_to_string_list(feature_value: List[Any]):
423422
"""Convert a list of feature values to a list of strings.
424423
425424
Args:
@@ -1173,8 +1172,9 @@ def ingest(
11731172
feature_group_name=self.name,
11741173
feature_definitions=feature_definition_dict,
11751174
sagemaker_session=self.sagemaker_session,
1176-
sagemaker_fs_runtime_client_config
1177-
=self.sagemaker_session.sagemaker_featurestore_runtime_client.meta.config,
1175+
sagemaker_fs_runtime_client_config=(
1176+
self.sagemaker_session.sagemaker_featurestore_runtime_client.meta.config
1177+
),
11781178
max_workers=max_workers,
11791179
max_processes=max_processes,
11801180
profile_name=profile_name,

tests/unit/test_session.py

Lines changed: 12 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -5275,33 +5275,29 @@ def test_feature_group_put_record(sagemaker_session_with_fs_runtime_client):
52755275
feature_group_name="MyFeatureGroup",
52765276
record=[{"FeatureName": "feature1", "ValueAsString": "value1"}],
52775277
)
5278-
assert (
5279-
sagemaker_session_with_fs_runtime_client.sagemaker_featurestore_runtime_client
5280-
.put_record.called_with(
5281-
FeatureGroupName="MyFeatureGroup",
5282-
record=[{"FeatureName": "feature1", "ValueAsString": "value1"}],
5283-
)
5284-
)
5278+
fs_client_mock = sagemaker_session_with_fs_runtime_client.sagemaker_featurestore_runtime_client
52855279

5280+
assert fs_client_mock.put_record.called_with(
5281+
FeatureGroupName="MyFeatureGroup",
5282+
record=[{"FeatureName": "feature1", "ValueAsString": "value1"}],
5283+
)
52865284

52875285

52885286
def test_feature_group_put_record_with_ttl_and_target_stores(
5289-
sagemaker_session_with_fs_runtime_client,
5287+
sagemaker_session_with_fs_runtime_client,
52905288
):
52915289
sagemaker_session_with_fs_runtime_client.put_record(
52925290
feature_group_name="MyFeatureGroup",
52935291
record=[{"FeatureName": "feature1", "ValueAsString": "value1"}],
52945292
ttl_duration={"Unit": "Seconds", "Value": 123},
52955293
target_stores=["OnlineStore", "OfflineStore"],
52965294
)
5297-
assert (
5298-
sagemaker_session_with_fs_runtime_client.sagemaker_featurestore_runtime_client
5299-
.put_record.called_with(
5300-
FeatureGroupName="MyFeatureGroup",
5301-
record=[{"FeatureName": "feature1", "ValueAsString": "value1"}],
5302-
target_stores=["OnlineStore", "OfflineStore"],
5303-
ttl_duration={"Unit": "Seconds", "Value": 123},
5304-
)
5295+
fs_client_mock = sagemaker_session_with_fs_runtime_client.sagemaker_featurestore_runtime_client
5296+
assert fs_client_mock.put_record.called_with(
5297+
FeatureGroupName="MyFeatureGroup",
5298+
record=[{"FeatureName": "feature1", "ValueAsString": "value1"}],
5299+
target_stores=["OnlineStore", "OfflineStore"],
5300+
ttl_duration={"Unit": "Seconds", "Value": 123},
53055301
)
53065302

53075303

0 commit comments

Comments
 (0)