fix: Provision online store infra for remote feast apply

`feast apply` against `online_store: type: remote` registered feature views but never created their tables, so `feast materialize` failed with HTTP 500 and `no such table`. `RemoteOnlineStore.update()` and `.teardown()` were both `pass`, and the feature server never calls `update_infra()` on its own -- it only refreshes the registry. Since table DDL lives exclusively in the concrete online store's `update()`, this affected any online store behind `type: remote`, not just SQLite. RemoteOnlineStore.update()/teardown() now call two new feature server endpoints, /update-infra and /teardown-infra, which run update_infra() and teardown_infra() against the server's real online store. The objects travel in the request body as base64-encoded protos rather than being looked up server-side by name, because FeatureStore.apply() calls update_infra() *before* registry.commit() -- at that point the server cannot see them yet, and with a file registry they are not even on disk. Authorization reuses the existing CREATE and DELETE actions, so no new permission surface is introduced. Fixes #6693 Signed-off-by: Rishabh <158596025+RishabhCodezZz@users.noreply.github.com>
RishabhCodezZz · Aug 19, 2026 · Aug 19, 2026 · Aug 22, 2026 · Aug 22, 2026 · Aug 25, 2026
commit bd367e48d8f412d6ea65f2c04cd20d6e58ddfa2e
@@ -643,6 +643,8 @@ The [PyTorch NLP template](https://github.com/feast-dev/feast/tree/main/sdk/pyth
 | /write-to-online-store     | FeatureView                     | Write Online                                          | Write features to the online store                             |
 | /materialize               | FeatureView                     | Write Online                                          | Materialize features within a specified time range             |
 | /materialize-incremental   | FeatureView                     | Write Online                                          | Incrementally materialize features up to a specified timestamp |
+| /update-infra              | FeatureView                     | Create, Delete                                        | Provision online store infrastructure for a remote `feast apply` |
+| /teardown-infra            | FeatureView                     | Delete                                                | Drop online store infrastructure for a remote `feast teardown`   |
 
 ## How to configure Authentication and Authorization ?
 

@@ -83,6 +83,29 @@ class WriteToFeatureStoreRequest(BaseModel):
     transform_on_write: bool = True
 
 
+class UpdateInfraRequest(BaseModel):
+    """Objects to provision, sent by RemoteOnlineStore.update().
+
+    Each entry is `{"type": <class name>, "proto": <base64 proto>}`. They are
+    carried in the body rather than looked up in the registry because
+    `FeatureStore.apply()` runs `update_infra()` before `registry.commit()`,
+    so the server cannot see them yet.
+    """
+
+    tables_to_delete: List[Dict[str, str]] = []
+    tables_to_keep: List[Dict[str, str]] = []
+    entities_to_delete: List[Dict[str, str]] = []
+    entities_to_keep: List[Dict[str, str]] = []
+    partial: bool = False
+
+
+class TeardownInfraRequest(BaseModel):
+    """Objects to tear down, sent by RemoteOnlineStore.teardown()."""
+
+    tables: List[Dict[str, str]] = []
+    entities: List[Dict[str, str]] = []
+
+
 class PushFeaturesRequest(BaseModel):
     push_source_name: str
     df: dict
@@ -932,6 +955,60 @@ async def write_to_online_store(request: WriteToFeatureStoreRequest) -> None:
             transform_on_write=request.transform_on_write,
         )
 
+    @app.post("/update-infra", dependencies=[Depends(inject_user_details)])
+    async def update_infra(request: UpdateInfraRequest) -> None:
+        """Provision online store infrastructure on behalf of a remote client.
+
+        `feast apply` against `online_store: type: remote` cannot create tables
+        itself -- the concrete online store lives here. Without this the feature
+        view is registered but its table never exists (#6693).
+        """
+        # Imported here, not at module scope: feast.infra.online_stores.remote
+        # imports from `feast`, which is still initializing when this module loads.
+        from feast.infra.online_stores.remote import decode_infra_object
+
+        tables_to_keep = [decode_infra_object(o) for o in request.tables_to_keep]
+        tables_to_delete = [decode_infra_object(o) for o in request.tables_to_delete]
+        entities_to_keep = [decode_infra_object(o) for o in request.entities_to_keep]
+        entities_to_delete = [
+            decode_infra_object(o) for o in request.entities_to_delete
+        ]
+
+        for table in tables_to_keep:
+            assert_permissions(resource=table, actions=[AuthzedAction.CREATE])
+        for table in tables_to_delete:
+            assert_permissions(resource=table, actions=[AuthzedAction.DELETE])
+
+        await run_in_threadpool(
+            store._get_provider().update_infra,
+            project=store.project,
+            tables_to_delete=tables_to_delete,
+            tables_to_keep=tables_to_keep,
+            entities_to_delete=entities_to_delete,
+            entities_to_keep=entities_to_keep,
+            partial=request.partial,
+        )
+
+    @app.post("/teardown-infra", dependencies=[Depends(inject_user_details)])
+    async def teardown_infra(request: TeardownInfraRequest) -> None:
+        """Drop online store infrastructure on behalf of a remote client."""
+        # Imported here, not at module scope: feast.infra.online_stores.remote
+        # imports from `feast`, which is still initializing when this module loads.
+        from feast.infra.online_stores.remote import decode_infra_object
+
+        tables = [decode_infra_object(o) for o in request.tables]
+        entities = [decode_infra_object(o) for o in request.entities]
+
+        for table in tables:
+            assert_permissions(resource=table, actions=[AuthzedAction.DELETE])
+
+        await run_in_threadpool(
+            store._get_provider().teardown_infra,
+            project=store.project,
+            tables=tables,
+            entities=entities,
+        )
+
     @app.get("/health")
     async def health():
         try:

@@ -11,6 +11,7 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+import base64
 import json
 import logging
 import uuid as uuid_module
@@ -60,6 +61,67 @@
 logger = logging.getLogger(__name__)
 
 
+def _infra_object_types() -> Dict[str, Tuple[Any, Any]]:
+    """Map type name -> (feast class, proto class) for objects sent to /update-infra.
+
+    Imported lazily: these modules import from `feast` at module scope, and
+    pulling them in at the top of this file would create an import cycle.
+    """
+    from feast.labeling.label_view import LabelView
+    from feast.on_demand_feature_view import OnDemandFeatureView
+    from feast.protos.feast.core.Entity_pb2 import Entity as EntityProto
+    from feast.protos.feast.core.FeatureView_pb2 import FeatureView as FeatureViewProto
+    from feast.protos.feast.core.LabelView_pb2 import LabelView as LabelViewProto
+    from feast.protos.feast.core.OnDemandFeatureView_pb2 import (
+        OnDemandFeatureView as OnDemandFeatureViewProto,
+    )
+    from feast.protos.feast.core.StreamFeatureView_pb2 import (
+        StreamFeatureView as StreamFeatureViewProto,
+    )
+    from feast.stream_feature_view import StreamFeatureView
+
+    return {
+        "FeatureView": (FeatureView, FeatureViewProto),
+        "StreamFeatureView": (StreamFeatureView, StreamFeatureViewProto),
+        "OnDemandFeatureView": (OnDemandFeatureView, OnDemandFeatureViewProto),
+        "LabelView": (LabelView, LabelViewProto),
+        "Entity": (Entity, EntityProto),
+    }
+
+
+def encode_infra_object(obj: Any) -> Dict[str, str]:
+    """Serialize a feature view or entity for transport to the feature server.
+
+    The registry is not a usable channel here: `FeatureStore.apply()` calls
+    `update_infra()` *before* `registry.commit()`, so the server cannot yet see
+    these objects. They travel in the request body instead.
+    """
+    type_name = type(obj).__name__
+    if type_name not in _infra_object_types():
+        raise ValueError(
+            f"Cannot send {type_name} to the remote online store; "
+            f"expected one of {sorted(_infra_object_types())}"
+        )
+    return {
+        "type": type_name,
+        "proto": base64.b64encode(obj.to_proto().SerializeToString()).decode("ascii"),
+    }
+
+
+def decode_infra_object(payload: Mapping[str, str]) -> Any:
+    """Inverse of :func:`encode_infra_object`, used by the feature server."""
+    type_name = payload["type"]
+    types = _infra_object_types()
+    if type_name not in types:
+        raise ValueError(
+            f"Unknown object type {type_name!r}; expected one of {sorted(types)}"
+        )
+    feast_class, proto_class = types[type_name]
+    return feast_class.from_proto(
+        proto_class.FromString(base64.b64decode(payload["proto"]))
+    )
+
+
 def _json_safe(val: Any) -> Any:
     """Convert uuid.UUID objects and sets to JSON-serializable form."""
     if isinstance(val, uuid_module.UUID):
@@ -742,15 +804,61 @@ def update(
         entities_to_keep: Sequence[Entity],
         partial: bool,
     ):
-        pass
+        """Provision online store infrastructure through the feature server.
+
+        Table creation happens inside the concrete online store's `update()`.
+        In remote mode that store lives server-side, so `feast apply` has to ask
+        the feature server to run it -- otherwise the feature view is registered
+        but its table never exists, and materialization fails with a missing
+        table (#6693).
+        """
+        assert isinstance(config.online_store, RemoteOnlineStoreConfig)
+        config.online_store.__class__ = RemoteOnlineStoreConfig
+
+        req_body = {
+            "tables_to_delete": [encode_infra_object(t) for t in tables_to_delete],
+            "tables_to_keep": [encode_infra_object(t) for t in tables_to_keep],
+            "entities_to_delete": [encode_infra_object(e) for e in entities_to_delete],
+            "entities_to_keep": [encode_infra_object(e) for e in entities_to_keep],
+            "partial": partial,
+        }
+
+        response = post_remote_update_infra(config=config, req_body=req_body)
+        if response.status_code != 200:
+            error_msg = (
+                "Unable to update online store infrastructure using feature server API. "
+                f"Error_code={response.status_code}, error_message={response.text}"
+            )
+            logger.error(error_msg)
+            raise RuntimeError(error_msg)
 
     def teardown(
         self,
         config: RepoConfig,
         tables: Sequence[FeatureView],
         entities: Sequence[Entity],
     ):
-        pass
+        """Drop online store infrastructure through the feature server.
+
+        The mirror of :meth:`update`: without this, `feast teardown` in remote
+        mode leaves every table behind.
+        """
+        assert isinstance(config.online_store, RemoteOnlineStoreConfig)
+        config.online_store.__class__ = RemoteOnlineStoreConfig
+
+        req_body = {
+            "tables": [encode_infra_object(t) for t in tables],
+            "entities": [encode_infra_object(e) for e in entities],
+        }
+
+        response = post_remote_teardown_infra(config=config, req_body=req_body)
+        if response.status_code != 200:
+            error_msg = (
+                "Unable to teardown online store infrastructure using feature server API. "
+                f"Error_code={response.status_code}, error_message={response.text}"
+            )
+            logger.error(error_msg)
+            raise RuntimeError(error_msg)
 
     async def close(self) -> None:
         """
@@ -812,3 +920,25 @@ def post_remote_online_write(
         return session.post(url, json=req_body, verify=config.online_store.cert)
     else:
         return session.post(url, json=req_body)
+
+
+@rest_error_handling_decorator
+def post_remote_update_infra(
+    session: requests.Session, config: RepoConfig, req_body: dict
+) -> requests.Response:
+    url = f"{config.online_store.path}/update-infra"
+    if config.online_store.cert:
+        return session.post(url, json=req_body, verify=config.online_store.cert)
+    else:
+        return session.post(url, json=req_body)
+
+
+@rest_error_handling_decorator
+def post_remote_teardown_infra(
+    session: requests.Session, config: RepoConfig, req_body: dict
+) -> requests.Response:
+    url = f"{config.online_store.path}/teardown-infra"
+    if config.online_store.cert:
+        return session.post(url, json=req_body, verify=config.online_store.cert)
+    else:
+        return session.post(url, json=req_body)