Skip to content

Commit 38850cc

Browse files
ntkatholentkathole
committed
feat: Added Ray Compute Engine
Signed-off-by: ntkathole <[email protected]>
1 parent 68cd9b3 commit 38850cc

27 files changed

Lines changed: 3468 additions & 910 deletions

File tree

‎Makefile‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -320,6 +320,11 @@ test-python-universal-ray-offline: ## Run Python Ray offline store integration t
320320
not test_spark" \
321321
sdk/python/tests
322322

323+
test-python-ray-compute-engine: ## Run Python Ray compute engine tests
324+
PYTHONPATH='.' \
325+
python -m pytest --integration \
326+
sdk/python/tests/integration/compute_engines/ray_compute/
327+
323328
test-python-universal-postgres-online: ## Run Python Postgres integration tests
324329
PYTHONPATH='.' \
325330
FULL_REPO_CONFIGS_MODULE=sdk.python.feast.infra.online_stores.postgres_online_store.postgres_repo_configuration \

‎docs/SUMMARY.md‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,7 @@
107107
* [Trino (contrib)](reference/offline-stores/trino.md)
108108
* [Azure Synapse + Azure SQL (contrib)](reference/offline-stores/mssql.md)
109109
* [Clickhouse (contrib)](reference/offline-stores/clickhouse.md)
110+
* [Ray (contrib)](reference/offline-stores/ray.md)
110111
* [Remote Offline](reference/offline-stores/remote-offline-store.md)
111112
* [Online stores](reference/online-stores/README.md)
112113
* [Overview](reference/online-stores/overview.md)
@@ -143,6 +144,7 @@
143144
* [Snowflake](reference/compute-engine/snowflake.md)
144145
* [AWS Lambda (alpha)](reference/compute-engine/lambda.md)
145146
* [Spark (contrib)](reference/compute-engine/spark.md)
147+
* [Ray (contrib)](reference/compute-engine/ray.md)
146148
* [Feature repository](reference/feature-repository/README.md)
147149
* [feature\_store.yaml](reference/feature-repository/feature-store-yaml.md)
148150
* [.feastignore](reference/feature-repository/feast-ignore.md)

‎docs/reference/compute-engine/README.md‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,14 @@ An example of built output from FeatureBuilder:
5757
- Supports point-in-time joins and large-scale materialization
5858
- Integrates with `SparkOfflineStore` and `SparkMaterializationJob`
5959

60+
### ⚡ RayComputeEngine (contrib)
61+
62+
- Distributed DAG execution via Ray
63+
- Intelligent join strategies (broadcast vs distributed)
64+
- Automatic resource management and optimization
65+
- Integrates with `RayOfflineStore` and `RayMaterializationJob`
66+
- See [Ray Compute Engine documentation](ray.md) for details
67+
6068
### 🧪 LocalComputeEngine
6169

6270
{% page-ref page="local.md" %}

0 commit comments

Comments
 (0)