Function _push_with_to

sdk/python/feast/feature_server.py:537–572

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_sup

(push_to: PushMode)

                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(
                        push_source_name=push_source_name,
                        df=df,
                        allow_registry_cache=allow_registry_cache,
                        to=push_to,
                        transform_on_write=transform_on_write,
                    )
                else:
                    await run_in_threadpool(
                        lambda: store.push(
                            push_source_name=push_source_name,
                            df=df,
                            allow_registry_cache=allow_registry_cache,
                            to=push_to,
                            transform_on_write=transform_on_write,
                        )
                    )

            needs_online = to in (PushMode.ONLINE, PushMode.ONLINE_AND_OFFLINE)
            needs_offline = to in (PushMode.OFFLINE, PushMode.ONLINE_AND_OFFLINE)