Function _populate_response_from_feature_data

sdk/python/feast/utils.py:1582–1683

Populate the GetOnlineFeaturesResponse from raw online_read rows. Converts raw rows from the OnlineStore into protobuf FeatureVectors and appends them to the response. This method assumes that ``online_read`` returns data for each unique entity in the same order as ``indexes``. Arg

(
    requested_features: List[str],
    read_rows: List[Tuple[Optional[datetime], Optional[Dict[str, ValueProto]]]],
    indexes: Iterable[List[int]],
    online_features_response: GetOnlineFeaturesResponse,
    full_feature_names: bool,
    table: "FeatureView",
    output_len: int,
    include_feature_view_version_metadata: bool = False,
)

def _populate_response_from_feature_data(
    requested_features: List[str],
    read_rows: List[Tuple[Optional[datetime], Optional[Dict[str, ValueProto]]]],
    indexes: Iterable[List[int]],
    online_features_response: GetOnlineFeaturesResponse,
    full_feature_names: bool,
    table: "FeatureView",
    output_len: int,
    include_feature_view_version_metadata: bool = False,
):
    """Populate the GetOnlineFeaturesResponse from raw online_read rows.

    Converts raw rows from the OnlineStore into protobuf FeatureVectors and
    appends them to the response. This method assumes that ``online_read``
    returns data for each unique entity in the same order as ``indexes``.

    Args:
        requested_features: The names of the features to extract from
            each row. Determines the order of FeatureVectors in the response.
        read_rows: Raw output from ``OnlineStore.online_read`` — a list of
            ``(event_timestamp, feature_dict)`` tuples, one per unique entity.
            ``feature_dict`` may be ``None`` when the entity is not found.
        indexes: A tuple of lists that maps each unique entity (by position
            in ``read_rows``) to one or more output positions in the response.
            Used to fan-out deduplicated reads back to the original request rows.
        online_features_response: The protobuf response object to populate.
        full_feature_names: If True, feature names are prefixed with the
            feature view name (e.g. ``"driver_fv__trips_today"``).
        table: The FeatureView that ``read_rows`` was retrieved from.
        output_len: Total number of result rows in the response.
        include_feature_view_version_metadata: If True, version metadata
            for the feature view is added to the response.
    """
    n_features = len(requested_features)

    table_name = table.projection.name_to_use()
    clean_table_name = table.projection.name_alias or table.projection.name
    feature_refs = [
        f"{table_name}__{fn}" if full_feature_names else fn for fn in requested_features
    ]
    online_features_response.metadata.feature_names.val.extend(feature_refs)

    if include_feature_view_version_metadata:
        existing_names = [
            fvm.name for fvm in online_features_response.metadata.feature_view_metadata
        ]
        if clean_table_name not in existing_names:
            fv_metadata = online_features_response.metadata.feature_view_metadata.add()
            fv_metadata.name = clean_table_name
            fv_metadata.version = getattr(table, "current_version_number", 0) or 0

    null_value = ValueProto()
    null_ts = Timestamp()
    PRESENT = FieldStatus.PRESENT
    NOT_FOUND = FieldStatus.NOT_FOUND

    row_ts_protos = []
    for row_ts, _ in read_rows: