diff --git a/sdk/python/feast/infra/key_encoding_utils.py b/sdk/python/feast/infra/key_encoding_utils.py index 18127896bd5..ce2692a4955 100644 --- a/sdk/python/feast/infra/key_encoding_utils.py +++ b/sdk/python/feast/infra/key_encoding_utils.py @@ -83,6 +83,8 @@ def serialize_entity_key( ) output: List[bytes] = [] + if entity_key_serialization_version > 2: + output.append(struct.pack(" 2: @@ -122,7 +124,11 @@ def deserialize_entity_key( offset = 0 keys = [] values = [] - while offset < len(serialized_entity_key): + + num_keys = struct.unpack_from("