fix: fix ray lance sink error

lancedb · Dec 30, 2024 · 7943f7e · 7943f7e
1 parent c237bcb
commit 7943f7e
Showing 1 changed file with 10 additions and 0 deletions.
diff --git 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: