Merge branch 'master' into feat/iceberg-local-materialization-sink

Author: haoxu0

Makefile

@@ -109,14 +109,10 @@ install-python-dependencies-ci: ## Install Python CI dependencies using uv pip s
 		echo "Creating virtualenv..."; \
 		uv venv .venv; \
 	fi
-	# Install CPU-only torch first to prevent CUDA dependency issues (Linux only)
-	@if [ "$$(uname -s)" = "Linux" ]; then \
-		echo "Installing dependencies with torch CPU index for Linux..."; \
-		uv pip sync --torch-backend cpu sdk/python/requirements/py$(PYTHON_VERSION)-ci-requirements.txt; \
-	else \
-		echo "Installing dependencies from PyPI for macOS..."; \
-		uv pip sync sdk/python/requirements/py$(PYTHON_VERSION)-ci-requirements.txt; \
-	fi
+	# Must match the --torch-backend used to compile the CI lock, otherwise the
+	# recorded CPU-wheel hashes (from download.pytorch.org) fail to verify.
+	# The lock is universal, so one command serves both Linux and macOS.
+	uv pip sync --torch-backend cpu sdk/python/requirements/py$(PYTHON_VERSION)-ci-requirements.txt
 	uv pip install --no-deps -e .
 
 # Used in github actions/ci
@@ -139,7 +135,8 @@ lock-python-dependencies-all: ## Recompile and lock all Python dependency sets f
 	rm -rf sdk/python/requirements/* 2>/dev/null || true
 	$(foreach ver,$(PYTHON_VERSIONS),\
 		pixi run --environment $(call get_env_name,$(ver)) --manifest-path infra/scripts/pixi/pixi.toml \
-			"uv pip compile -p $(ver) --no-strip-extras pyproject.toml --extra ci \
+			"uv pip compile -p $(ver) --universal --no-strip-extras pyproject.toml --extra ci \
+			--torch-backend cpu \
 			--generate-hashes --output-file sdk/python/requirements/py$(ver)-ci-requirements.txt" && \
 		pixi run --environment $(call get_env_name,$(ver)) --manifest-path infra/scripts/pixi/pixi.toml \
 			"uv pip compile -p $(ver) --no-strip-extras pyproject.toml \

community/maintainers.md

@@ -11,6 +11,7 @@ In alphabetical order
 | Achal Shah     | `achals`         | achals@gmail.com            | Tecton             |
 | Francisco Javier Arceo   | `franciscojavierarceo`       | arceofrancisco@gmail.com          | Affirm          |
 | Hao Xu   | `HaoXuAI`       | sduxuhao@gmail.com          | JPMorgan          |
+| Nikhil Kathole | `ntkathole` | nikhilkathole2683@gmail.com | Red Hat |
 | Shuchu Han  | `shuchu`       | shuchu.han@gmail.com          | Independent          |
 | Willem Pienaar | `woop`           | will.pienaar@gmail.com      | Cleric             |
 | Zhiling Chen        | `zhilingc`     | chnzhlng@gmail.com        | GetGround         |

docs/how-to-guides/scaling-feast.md

@@ -8,12 +8,12 @@ Since Feast is designed to be modular, it's possible to swap such components wit
 
 ### Scaling Feast Registry
 
-The default Feast [registry](../getting-started/concepts/registry.md) is a file-based registry. Any changes to the feature repo, or materializing data into the online store, results in a mutation to the registry.
+The default Feast [registry](../getting-started/components/registry.md) is a file-based registry. Any changes to the feature repo, or materializing data into the online store, results in a mutation to the registry.
 
 However, there are inherent limitations with a file-based registry, since changing a single field in the registry requires re-writing the whole registry file.
 With multiple concurrent writers, this presents a risk of data loss, or bottlenecks writes to the registry since all changes have to be serialized (e.g. when running materialization for multiple feature views or time ranges concurrently).
 
-The recommended solution in this case is to use the [SQL based registry](../tutorials/using-scalable-registry.md), which allows concurrent, transactional, and fine-grained updates to the registry. This registry implementation requires access to an existing database (such as MySQL, Postgres, etc).
+The recommended solution in this case is to use the [SQL based registry](../reference/registries/sql.md), which allows concurrent, transactional, and fine-grained updates to the registry. This registry implementation requires access to an existing database (such as MySQL, Postgres, etc).
 
 ### Scaling Materialization
 

infra/feast-operator/Dockerfile

@@ -1,5 +1,5 @@
 # Build the manager binary
-FROM registry.access.redhat.com/ubi9/go-toolset:1.25 AS builder
+FROM registry.access.redhat.com/ubi9/go-toolset:1.26 AS builder
 ARG TARGETOS
 ARG TARGETARCH
 ENV GOTOOLCHAIN=auto

infra/scripts/pixi/pixi.toml

@@ -6,7 +6,7 @@ platforms = ["linux-64", "osx-arm64", "osx-64"]
 [tasks]
 
 [dependencies]
-uv = ">=0.6.3"
+uv = ">=0.6.9"
 
 [feature.py39.dependencies]
 python = "~=3.9.0"

pixi.lock

@@ -142,7 +142,7 @@ snowflake = [
     "snowflake-connector-python[pandas]>=3.7,<5",
 ]
 sqlite_vec = ["sqlite-vec==v0.1.6"]
-mcp = ["fastapi_mcp", "mcp>=1.0,<2"]
+mcp = ["fastapi_mcp", "mcp>=1.0,<1.30"]
 mlflow = ["mlflow>=2.10.0"]
 
 dbt = ["dbt-artifacts-parser"]

pyproject.toml

@@ -700,6 +700,8 @@ def _initialize_local_ray(config: Any, enable_logging: bool = False) -> None:
     ctx = DatasetContext.get_current()
     ctx.shuffle_strategy = "sort"  # type: ignore
     ctx.enable_tensor_extension_casting = False
+    if hasattr(ctx, "enable_arrow_backed_pandas_conversion"):
+        ctx.enable_arrow_backed_pandas_conversion = False
 
     # Log cluster info
     if enable_logging:
@@ -760,6 +762,8 @@ def _initialize_remote_ray(config: Any, enable_logging: bool = False) -> None:
     ctx = DatasetContext.get_current()
     ctx.shuffle_strategy = "sort"  # type: ignore
     ctx.enable_tensor_extension_casting = False
+    if hasattr(ctx, "enable_arrow_backed_pandas_conversion"):
+        ctx.enable_arrow_backed_pandas_conversion = False
 
     # Log cluster info
     if enable_logging:
@@ -853,6 +857,8 @@ def ensure_ray_initialized(
         ctx = DatasetContext.get_current()
         ctx.shuffle_strategy = "sort"  # type: ignore
         ctx.enable_tensor_extension_casting = False
+        if hasattr(ctx, "enable_arrow_backed_pandas_conversion"):
+            ctx.enable_arrow_backed_pandas_conversion = False
         if not enable_logging:
             _suppress_ray_logging()
         _ray_initialized = True

sdk/python/feast/infra/ray_initializer.py

@@ -63,8 +63,14 @@ def wrapper(
         nonlocal cache_key, cache_value
 
         kwargs_key = tuple(sorted(kwargs.items())) if kwargs else ()
-        key = tuple(
-            [id(registry_proto), registry_proto.version_id, project, tags, kwargs_key]
+        # Snapshot the filter so caller mutations cannot change a cached key.
+        tags_key = frozenset(tags.items()) if tags is not None else None
+        key = (
+            id(registry_proto),
+            registry_proto.version_id,
+            project,
+            tags_key,
+            kwargs_key,
         )
 
         if key == cache_key: