Function push

sdk/python/feast/feature_server.py:499–594

(request: PushFeaturesRequest)

    @app.post("/push", dependencies=[Depends(inject_user_details)])
    async def push(request: PushFeaturesRequest) -> Response:
        with feast_metrics.track_request_latency("/push"):
            df = pd.DataFrame(request.df)
            actions = []
            if request.to == "offline":
                to = PushMode.OFFLINE
                actions = [AuthzedAction.WRITE_OFFLINE]
            elif request.to == "online":
                to = PushMode.ONLINE
                actions = [AuthzedAction.WRITE_ONLINE]
            elif request.to == "online_and_offline":
                to = PushMode.ONLINE_AND_OFFLINE
                actions = WRITE
            else:
                raise ValueError(
                    f"{request.to} is not a supported push format. Please specify one of these ['online', 'offline', 'online_and_offline']."
                )

            from feast.data_source import PushSource

            all_fvs = store.list_feature_views(
                allow_cache=request.allow_registry_cache
            ) + store.list_stream_feature_views(
                allow_cache=request.allow_registry_cache
            )
            fvs_with_push_sources = {
                fv
                for fv in all_fvs
                if (
                    fv.stream_source is not None
                    and isinstance(fv.stream_source, PushSource)
                    and fv.stream_source.name == request.push_source_name
                )
            }

            for feature_view in fvs_with_push_sources:
                assert_permissions(resource=feature_view, actions=actions)

            async def _push_with_to(push_to: PushMode) -> None:
                """
                Helper for performing a single push operation.

                NOTE:
                - Feast providers **do not currently support async offline writes**.
                - Therefore:
                    * ONLINE and ONLINE_AND_OFFLINE → may be async, depending on provider.async_supported.online.write
                    * OFFLINE → always synchronous, but executed via run_in_threadpool when called from HTTP handlers.
                - The OfflineWriteBatcher handles offline writes directly in its own background thread, but the offline store writes are currently synchronous only.
                """
                push_source_name = request.push_source_name
                allow_registry_cache = request.allow_registry_cache
                transform_on_write = request.transform_on_write

                # Async currently only applies to online store writes (ONLINE / ONLINE_AND_OFFLINE paths) as theres no async for offline store
                if push_to in (PushMode.ONLINE, PushMode.ONLINE_AND_OFFLINE) and (
                    store._get_provider().async_supported.online.write
                ):
                    await store.push_async(