franciscojavierarceo · Apr 15, 2026 · Apr 13, 2026 · Apr 13, 2026 · Apr 14, 2026 · Apr 14, 2026
diff --git a/sdk/python/docs/source/feast.aggregation.rst b/sdk/python/docs/source/feast.aggregation.rst
@@ -0,0 +1,17 @@
+feast.aggregation package
+=========================
+
+Subpackages
+-----------
+
+.. toctree::
+   :maxdepth: 4
+
+   feast.aggregation.tiling
+
+Module contents
+---------------
+
+.. automodule:: feast.aggregation
+   :members:
+   :show-inheritance:
diff --git a/sdk/python/docs/source/feast.aggregation.tiling.rst b/sdk/python/docs/source/feast.aggregation.tiling.rst
@@ -0,0 +1,9 @@
+feast.aggregation.tiling package
+=================================
+
+Module contents
+---------------
+
+.. automodule:: feast.aggregation.tiling
+   :members:
+   :show-inheritance:
diff --git a/sdk/python/docs/source/feast.dbt.rst b/sdk/python/docs/source/feast.dbt.rst
@@ -0,0 +1,37 @@
+feast.dbt package
+=================
+
+Submodules
+----------
+
+feast.dbt.codegen module
+------------------------
+
+.. automodule:: feast.dbt.codegen
+   :members:
+   :undoc-members:
+   :show-inheritance:
+
+feast.dbt.mapper module
+-----------------------
+
+.. automodule:: feast.dbt.mapper
+   :members:
+   :undoc-members:
+   :show-inheritance:
+
+feast.dbt.parser module
+-----------------------
+
+.. automodule:: feast.dbt.parser
+   :members:
+   :undoc-members:
+   :show-inheritance:
+
+Module contents
+---------------
+
+.. automodule:: feast.dbt
+   :members:
+   :undoc-members:
+   :show-inheritance:
diff --git a/sdk/python/docs/source/feast.diff.rst b/sdk/python/docs/source/feast.diff.rst
@@ -4,6 +4,14 @@ feast.diff package
 Submodules
 ----------
 
+feast.diff.apply\_progress module
+----------------------------------
+
+.. automodule:: feast.diff.apply_progress
+   :members:
+   :undoc-members:
+   :show-inheritance:
+
 feast.diff.infra\_diff module
 -----------------------------
 

diff --git a/sdk/python/docs/source/feast.openlineage.rst b/sdk/python/docs/source/feast.openlineage.rst
@@ -0,0 +1,9 @@
+feast.openlineage package
+=========================
+
+Module contents
+---------------
+
+.. automodule:: feast.openlineage
+   :members:
+   :show-inheritance:
diff --git a/sdk/python/docs/source/feast.rst b/sdk/python/docs/source/feast.rst
@@ -7,13 +7,16 @@ Subpackages
 .. toctree::
    :maxdepth: 4
 
+   feast.aggregation
    feast.api
    feast.cli
+   feast.dbt
    feast.diff
    feast.dqm
    feast.embedded_go
    feast.infra
    feast.lineage
+   feast.openlineage
    feast.permissions
    feast.protos
    feast.transformation
@@ -22,14 +25,6 @@ Subpackages
 Submodules
 ----------
 
-feast.aggregation module
-------------------------
-
-.. automodule:: feast.aggregation
-   :members:
-   :undoc-members:
-   :show-inheritance:
-
 feast.arrow\_error\_handler module
 ----------------------------------
 

@@ -1,4 +1,5 @@
 import base64
+import logging
 from datetime import datetime
 from pathlib import Path
 from typing import Any, Callable, Dict, List, Literal, Optional, Sequence, Tuple, Union
@@ -42,6 +43,8 @@
     to_naive_utc,
 )
 
+logger = logging.getLogger(__name__)
+
 PROTO_TO_MILVUS_TYPE_MAPPING: Dict[ValueType, DataType] = {
     PROTO_VALUE_TO_VALUE_TYPE_MAP["bytes_val"]: DataType.VARCHAR,
     ValueType.IMAGE_BYTES: DataType.VARCHAR,
@@ -140,11 +143,13 @@ def _connect(self, config: RepoConfig) -> MilvusClient:
         if not self.client:
             if config.provider == "local" and config.online_store.path:
                 db_path = self._get_db_path(config)
-                print(f"Connecting to Milvus in local mode using {db_path}")
+                logger.info("Connecting to Milvus in local mode using %s", db_path)
                 self.client = MilvusClient(db_path)
             else:
-                print(
-                    f"Connecting to Milvus remotely at {config.online_store.host}:{config.online_store.port}"
+                logger.info(
+                    "Connecting to Milvus remotely at %s:%s",
+                    config.online_store.host,
+                    config.online_store.port,
                 )
                 self.client = MilvusClient(
                     uri=f"{config.online_store.host}:{config.online_store.port}",
@@ -339,7 +344,6 @@ def online_read(
         table: FeatureView,
         entity_keys: List[EntityKeyProto],
         requested_features: Optional[List[str]] = None,
-        full_feature_names: bool = False,
     ) -> List[Tuple[Optional[datetime], Optional[Dict[str, ValueProto]]]]:
         self.client = self._connect(config)
         collection_name = _table_id(config.project, table)
@@ -487,7 +491,7 @@ def update(
     ):
         self.client = self._connect(config)
         for table in tables_to_keep:
-            self._collections = self._get_or_create_collection(config, table)
+            self._get_or_create_collection(config, table)
 
         for table in tables_to_delete:
             collection_name = _table_id(config.project, table)
@@ -498,7 +502,7 @@ def update(
     def plan(
         self, config: RepoConfig, desired_registry_proto: RegistryProto
     ) -> List[InfraObject]:
-        raise NotImplementedError
+        return []
 
     def teardown(
         self,
@@ -686,9 +690,8 @@ def retrieve_online_documents_v2(
             for hit in hits:
                 res = {}
                 res_ts = None
-                entity_key_bytes = bytes.fromhex(
-                    hit.get("entity", {}).get(composite_key_name, None)
-                )
+                raw_key = hit.get("entity", {}).get(composite_key_name)
+                entity_key_bytes = bytes.fromhex(raw_key) if raw_key else None
                 entity_key_proto = (
                     deserialize_entity_key(entity_key_bytes)
                     if entity_key_bytes

diff --git a/sdk/python/feast/openlineage/__init__.py b/sdk/python/feast/openlineage/__init__.py
@@ -35,27 +35,27 @@
 Usage:
     Simply configure OpenLineage in your feature_store.yaml:
 
-    ```yaml
-    project: my_project
-    # ... other config ...
-
-    openlineage:
-      enabled: true
-      transport_type: http
-      transport_url: http://localhost:5000
-      transport_endpoint: api/v1/lineage
-      namespace: my_namespace  # Optional: defaults to project name
-    ```
+    .. code-block:: yaml
+
+        project: my_project
+        # ... other config ...
+
+        openlineage:
+          enabled: true
+          transport_type: http
+          transport_url: http://localhost:5000
+          transport_endpoint: api/v1/lineage
+          namespace: my_namespace  # Optional: defaults to project name
 
     Then use Feast normally - lineage events are emitted automatically!
 
-    ```python
-    from feast import FeatureStore
+    .. code-block:: python
+
+        from feast import FeatureStore
 
-    fs = FeatureStore(repo_path="feature_repo")
-    fs.apply([entity, feature_view, feature_service])  # Emits lineage
-    fs.materialize(start, end)  # Emits START/COMPLETE/FAIL events
-    ```
+        fs = FeatureStore(repo_path="feature_repo")
+        fs.apply([entity, feature_view, feature_service])  # Emits lineage
+        fs.materialize(start, end)  # Emits START/COMPLETE/FAIL events
 """
 
 from feast.openlineage.client import FeastOpenLineageClient

diff --git a/sdk/python/feast/openlineage/client.py b/sdk/python/feast/openlineage/client.py
@@ -55,7 +55,8 @@ class FeastOpenLineageClient:
     from Feast operations like materialization, feature retrieval, and
     registry changes.
 
-    Example:
+    Example::
+
         from feast.openlineage import FeastOpenLineageClient, OpenLineageConfig
 
         config = OpenLineageConfig(

diff --git a/sdk/python/feast/openlineage/emitter.py b/sdk/python/feast/openlineage/emitter.py
@@ -644,11 +644,13 @@ def emit_apply(
         1. feast_feature_views_{project}: DataSources + Entities → FeatureViews
         2. feast_feature_services_{project}: FeatureViews → FeatureServices
 
-        This creates a lineage graph matching Feast UI:
+        This creates a lineage graph matching Feast UI::
+
             DataSource ──→ FeatureView ──→ FeatureService
                  ↑
               Entity
 
+
         Args:
             objects: List of Feast objects being applied
             project: Project name

diff --git a/sdk/python/feast/repo_config.py b/sdk/python/feast/repo_config.py
@@ -337,7 +337,7 @@ class RepoConfig(FeastBaseModel):
     """ MaterializationConfig: Configuration options for feature materialization behavior. """
 
     openlineage_config: Optional[OpenLineageConfig] = Field(None, alias="openlineage")
-    """ OpenLineageConfig: Configuration for OpenLineage data lineage integration (optional). """
+    """ Configuration for OpenLineage data lineage integration (optional). """
 
     def __init__(self, **data: Any):
         super().__init__(**data)