diff --git a/python/python/lance/ray/sink.py b/python/python/lance/ray/sink.py
index 7cde7eada1..786245b19a 100644
--- a/python/python/lance/ray/sink.py
+++ b/python/python/lance/ray/sink.py
@@ -130,6 +130,16 @@ def on_write_complete(
         self,
         write_results: List[List[Tuple[str, str]]],
     ):
+        import warnings
+
+        warnings.warn(
+            "write_result_blocks is empty.",
+            DeprecationWarning,
+        )
+        return "Empty list"
+
+        if hasattr(write_results, "write_returns"):
+            write_results = write_results.write_returns
         fragments = []
         schema = None
         for batch in write_results: