From a5445ae3e7a9d27960aef722a61141c3f4b7b20d Mon Sep 17 00:00:00 2001
From: soffer-anyscale <stephen.offer@anyscale.com>
Date: Mon, 28 Jul 2025 10:39:40 -0700
Subject: [PATCH] added version arg

Signed-off-by: soffer-anyscale <stephen.offer@anyscale.com>
---
 python/ray/data/read_api.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/python/ray/data/read_api.py b/python/ray/data/read_api.py
index dd0198521a24..0590f6a17fde 100644
--- a/python/ray/data/read_api.py
+++ b/python/ray/data/read_api.py
@@ -3858,6 +3858,7 @@ def read_unity_catalog(
 @PublicAPI(stability="alpha")
 def read_delta(
     path: Union[str, List[str]],
+    version: Optional[int] = None,
     *,
     filesystem: Optional["pyarrow.fs.FileSystem"] = None,
     columns: Optional[List[str]] = None,
@@ -3882,6 +3883,7 @@ def read_delta(
     Args:
         path: A single file path for a Delta Lake table. Multiple tables are not yet
             supported.
+        version: The version of the Delta Lake table to read. If not specified, the latest version is read.
         filesystem: The PyArrow filesystem
             implementation to read from. These filesystems are specified in the
             `pyarrow docs <https://arrow.apache.org/docs/python/api/\
@@ -3946,7 +3948,7 @@ def read_delta(
         raise ValueError("Only a single Delta Lake table path is supported.")
 
     # Get the parquet file paths from the DeltaTable
-    paths = DeltaTable(path).file_uris()
+    paths = DeltaTable(path, version=version).file_uris()
     file_extensions = ["parquet"]
 
     return read_parquet(