Ray fix

Minor change in Ray dependency.

Author: turukawa

CHANGELOG

@@ -1,3 +1,4 @@
+- 1.2.3: Minor change in Ray dependency.
 - 1.2.2: Fix to date ISO conversion where date str already in ISO-format, plus Ray dependency fix.
 - 1.2.1: Minor change in Ray dependency.
 - 1.2.0: Upgrading Pydantic from version 1.8 to version 2.10.

docs/changelog.md

@@ -3,11 +3,15 @@ title: Change log
 summary: Version history, including for legacy versions.
 authors:
   - Gavin Chait
-date: 2025-09-11
+date: 2025-09-12
 tags: wrangling, crosswalks, versions
 ---
 # Change log
 
+## Version 1.2.3 (2025-09-12)
+
+- Minor change in Ray dependency.
+
 ## Version 1.2.2 (2025-09-11)
 
 - Fix to ISO date conversion where string is already in ISO-format.

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "whyqd"
-version = "1.2.2"
+version = "1.2.3"
 description = "data wrangling simplicity, complete audit transparency, and at speed"
 authors = ["Gavin Chait <gchait@whythawk.com>"]
 license = "BSD-3-Clause"

whyqd/VERSION

@@ -1 +1 @@
-1.2.2
+1.2.3

whyqd/config/ray_init.py

@@ -10,8 +10,10 @@
 def clear_spillway() -> bool:
     # https://stackoverflow.com/a/56151260/295606
     # only do this if ray is not initialised, otherwise it'll crash. horribly.
-    # WHYQD_SPILLWAY = ray._common.utils.get_user_temp_dir()
-    WHYQD_SPILLWAY = ray._private.utils.get_user_temp_dir()
+    try:
+        WHYQD_SPILLWAY = ray._common.utils.get_user_temp_dir()
+    except AttributeError:
+        WHYQD_SPILLWAY = ray._private.utils.get_user_temp_dir()
     if not Path(WHYQD_SPILLWAY).exists():
         return False
     for path in Path(WHYQD_SPILLWAY).iterdir():
@@ -51,8 +53,12 @@ def ray_start(**kwargs):
             kwargs["object_store_memory"] = settings.WHYQD_MEMORY
         if not kwargs.get("_temp_dir") and settings.WHYQD_SPILLWAY:
             # TODO: On some environments, I'm getting weird timeouts
-            if not ray._private.utils.get_user_temp_dir().endswith(settings.WHYQD_SPILLWAY):
-                kwargs["_temp_dir"] = f"{ray._private.utils.get_user_temp_dir()}{settings.WHYQD_SPILLWAY}"
+            try:
+                WHYQD_SPILLWAY = ray._common.utils.get_user_temp_dir()
+            except AttributeError:
+                WHYQD_SPILLWAY = ray._private.utils.get_user_temp_dir()
+            if not WHYQD_SPILLWAY.endswith(settings.WHYQD_SPILLWAY):
+                kwargs["_temp_dir"] = f"{WHYQD_SPILLWAY}{settings.WHYQD_SPILLWAY}"
             pass
         # if not kwargs.get("_system_config") and settings.WHYQD_SPILLWAY:
         #     kwargs["_system_config"] = {