Function _get_online_request_context

sdk/python/feast/utils.py:1310–1382

(
    registry,
    project,
    features: Union[List[str], "FeatureService"],
    full_feature_names: bool,
)

def _get_online_request_context(
    registry,
    project,
    features: Union[List[str], "FeatureService"],
    full_feature_names: bool,
):
    from feast.feature_view import DUMMY_ENTITY_NAME

    _feature_refs = _get_features(registry, project, features, allow_cache=True)

    (
        requested_feature_views,
        requested_on_demand_feature_views,
    ) = _get_feature_views_to_use(
        registry=registry,
        project=project,
        features=features,
        allow_cache=True,
        hide_dummy_entity=False,
    )

    (
        entity_name_to_join_key_map,
        entity_type_map,
        join_keys_set,
    ) = _get_entity_maps(registry, project, requested_feature_views)

    _validate_feature_refs(_feature_refs, full_feature_names)
    (
        grouped_refs,
        grouped_odfv_refs,
    ) = _group_feature_refs(
        _feature_refs,
        requested_feature_views,
        requested_on_demand_feature_views,
    )

    # Build expected result names, including version tag when present so
    # multi-version queries (e.g. fv@v1:feat, fv@v2:feat) match the response.
    requested_result_row_names = set()
    for feat_ref in _feature_refs:
        fv_name, version_num, feature_name = _parse_feature_ref(feat_ref)
        if full_feature_names:
            if version_num is not None:
                requested_result_row_names.add(
                    f"{fv_name}@v{version_num}__{feature_name}"
                )
            else:
                requested_result_row_names.add(f"{fv_name}__{feature_name}")
        else:
            requested_result_row_names.add(feature_name)

    feature_views = list(view for view, _ in grouped_refs)

    needed_request_data = get_needed_request_data(grouped_odfv_refs)

    entityless_case = DUMMY_ENTITY_NAME in [
        entity_name