Skip to content

Commit 4aa9d50

Browse files
committed
fix issues
Signed-off-by: Vanshika Vanshika <[email protected]> rh-pre-commit.version: 2.3.2 rh-pre-commit.check-secrets: ENABLED
1 parent a63d529 commit 4aa9d50

1 file changed

Lines changed: 15 additions & 3 deletions

File tree

sdk/python/feast/feature_store.py

Lines changed: 15 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3003,7 +3003,11 @@ def _doc_feature(x):
30033003
online_features_response=online_features_response,
30043004
data=requested_features_data,
30053005
)
3006-
return OnlineResponse(online_features_response)
3006+
feature_types = {
3007+
f.name: f.dtype.to_value_type()
3008+
for f in requested_feature_view.features
3009+
}
3010+
return OnlineResponse(online_features_response, feature_types=feature_types)
30073011

30083012
def retrieve_online_documents_v2(
30093013
self,
@@ -3293,7 +3297,12 @@ def _retrieve_from_online_store_v2(
32933297
online_features_response.metadata.feature_names.val.extend(
32943298
features_to_request
32953299
)
3296-
return OnlineResponse(online_features_response)
3300+
feature_types = {
3301+
f.name: f.dtype.to_value_type() for f in table.features
3302+
}
3303+
return OnlineResponse(
3304+
online_features_response, feature_types=feature_types
3305+
)
32973306

32983307
table_entity_values, idxs, output_len = utils._get_unique_entities_from_values(
32993308
entity_key_dict,
@@ -3316,7 +3325,10 @@ def _retrieve_from_online_store_v2(
33163325
data=entity_key_dict,
33173326
)
33183327

3319-
return OnlineResponse(online_features_response)
3328+
feature_types = {
3329+
f.name: f.dtype.to_value_type() for f in table.features
3330+
}
3331+
return OnlineResponse(online_features_response, feature_types=feature_types)
33203332

33213333
def serve(
33223334
self,

0 commit comments

Comments
 (0)