Skip to content

Commit c1a0b67

Browse files
committed
Ray minor fix
Ray has refactored the utils previously in `_private` to `_common`.
1 parent bc6ea31 commit c1a0b67

File tree

4 files changed

+6
-5
lines changed

4 files changed

+6
-5
lines changed

CHANGELOG

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
- 1.2.1: Minor change in Ray dependency
12
- 1.2.0: Upgrading Pydantic from version 1.8 to version 2.10
23
- 1.1.3: Improving exception error messages to be more helpful.
34
- 1.1.2: Fixes for `CATEGORY` parser for ambiguous term names.

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[tool.poetry]
22
name = "whyqd"
3-
version = "1.2.0"
3+
version = "1.2.1"
44
description = "data wrangling simplicity, complete audit transparency, and at speed"
55
authors = ["Gavin Chait <gchait@whythawk.com>"]
66
license = "BSD-3-Clause"

whyqd/VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
1.2.0
1+
1.2.1

whyqd/config/ray_init.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
def clear_spillway() -> bool:
1111
# https://stackoverflow.com/a/56151260/295606
1212
# only do this if ray is not initialised, otherwise it'll crash. horribly.
13-
WHYQD_SPILLWAY = ray._private.utils.get_user_temp_dir()
13+
WHYQD_SPILLWAY = ray._common.utils.get_user_temp_dir()
1414
if not Path(WHYQD_SPILLWAY).exists():
1515
return False
1616
for path in Path(WHYQD_SPILLWAY).iterdir():
@@ -50,8 +50,8 @@ def ray_start(**kwargs):
5050
kwargs["object_store_memory"] = settings.WHYQD_MEMORY
5151
if not kwargs.get("_temp_dir") and settings.WHYQD_SPILLWAY:
5252
# TODO: On some environments, I'm getting weird timeouts
53-
if not ray._private.utils.get_user_temp_dir().endswith(settings.WHYQD_SPILLWAY):
54-
kwargs["_temp_dir"] = f"{ray._private.utils.get_user_temp_dir()}{settings.WHYQD_SPILLWAY}"
53+
if not ray._common.utils.get_user_temp_dir().endswith(settings.WHYQD_SPILLWAY):
54+
kwargs["_temp_dir"] = f"{ray._common.utils.get_user_temp_dir()}{settings.WHYQD_SPILLWAY}"
5555
pass
5656
# if not kwargs.get("_system_config") and settings.WHYQD_SPILLWAY:
5757
# kwargs["_system_config"] = {

0 commit comments

Comments
 (0)