Function retrieve_online_documents

sdk/python/feast/feature_server.py:464–496

(
        request: GetOnlineDocumentsRequest,
    )

        response_model=OnlineFeaturesResponse,
    )
    async def retrieve_online_documents(
        request: GetOnlineDocumentsRequest,
    ) -> Any:
        with feast_metrics.track_request_latency("/retrieve-online-documents"):
            logger.warning(
                "This endpoint is in alpha and will be moved to /get-online-features when stable."
            )
            features = await _get_features(request, store)

            read_params = dict(
                features=features,
                query=request.query,
                top_k=request.top_k,
            )
            if request.api_version == 2 and request.query_string is not None:
                read_params["query_string"] = request.query_string

            if request.api_version == 2:
                read_params["include_feature_view_version_metadata"] = (
                    request.include_feature_view_version_metadata
                )
                response = await run_in_threadpool(
                    lambda: store.retrieve_online_documents_v2(**read_params)  # type: ignore
                )
            else:
                response = await run_in_threadpool(
                    lambda: store.retrieve_online_documents(**read_params)  # type: ignore
                )

            response_dict = await run_in_threadpool(
                convert_response_to_dict, response.proto
            )
            return JSONResponse(content=response_dict)

    @app.post("/push", dependencies=[Depends(inject_user_details)])
    async def push(request: PushFeaturesRequest) -> Response: