Seanshi/cached node addr

ci/ray_ci/utils.py

@@ -18,7 +18,7 @@
 GLOBAL_CONFIG_FILE = (
     os.environ.get("RAYCI_GLOBAL_CONFIG") or "ci/ray_ci/oss_config.yaml"
 )
-RAY_VERSION = "3.0.0.dev0"
+RAY_VERSION = "2.32.0"
 
 
 def ci_init() -> None:

java/api/pom_template.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.ray</groupId>
     <artifactId>ray-superpom</artifactId>
-    <version>2.0.0-SNAPSHOT</version>
+    <version>2.32.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

java/performance_test/pom_template.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.ray</groupId>
     <artifactId>ray-superpom</artifactId>
-    <version>2.0.0-SNAPSHOT</version>
+    <version>2.32.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

java/pom.xml

@@ -5,7 +5,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>io.ray</groupId>
   <artifactId>ray-superpom</artifactId>
-  <version>2.0.0-SNAPSHOT</version>
+  <version>2.32.0</version>
   <packaging>pom</packaging>
   <name>Ray Project Parent POM</name>
   <description>An open source framework that provides a simple, universal API for building distributed applications.
@@ -63,7 +63,7 @@
   <properties>
     <java.version>1.8</java.version>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    <project.version>2.0.0-SNAPSHOT</project.version>
+    <project.version>2.32.0</project.version>
   </properties>
 
   <dependencyManagement>

java/runtime/pom_template.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.ray</groupId>
     <artifactId>ray-superpom</artifactId>
-    <version>2.0.0-SNAPSHOT</version>
+    <version>2.32.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

java/serve/pom_template.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.ray</groupId>
     <artifactId>ray-superpom</artifactId>
-    <version>2.0.0-SNAPSHOT</version>
+    <version>2.32.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

java/test/pom_template.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.ray</groupId>
     <artifactId>ray-superpom</artifactId>
-    <version>2.0.0-SNAPSHOT</version>
+    <version>2.32.0</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

python/ray/_version.py

@@ -1,6 +1,6 @@
 # Replaced with the current commit when building the wheels.
 commit = "{{RAY_COMMIT_SHA}}"
-version = "3.0.0.dev0"
+version = "2.32.0"
 
 if __name__ == "__main__":
     print("%s %s" % (version, commit))

python/ray/train/_internal/utils.py

@@ -22,6 +22,9 @@
 from ray.exceptions import RayActorError
 from ray.types import ObjectRef
 
+# Terrible code importing
+from ray._private.worker import _global_node
+
 T = TypeVar("T")
 
 logger = logging.getLogger(__name__)
@@ -64,7 +67,7 @@ def check_for_failure(
 
 def get_address_and_port() -> Tuple[str, int]:
     """Returns the IP address and a free port on this node."""
-    addr = ray.util.get_node_ip_address()
+    addr = ray.util.get_cached_node_ip_address(_global_node.address_info["session_dir"])  # TODO this code is quite hacky
     port = find_free_port()
 
     return addr, port

python/ray/util/__init__.py

@@ -3,7 +3,7 @@
 import ray
 from ray._private.client_mode_hook import client_mode_hook
 from ray._private.auto_init_hook import wrap_auto_init
-from ray._private.services import get_node_ip_address
+from ray._private.services import get_cached_node_ip_address, get_node_ip_address
 from ray.util import iter
 from ray.util import rpdb as pdb
 from ray.util import debugpy as ray_debugpy
@@ -61,6 +61,7 @@ def list_named_actors(all_namespaces: bool = False) -> List[str]:
     "placement_group_table",
     "get_placement_group",
     "get_current_placement_group",
+    "get_cached_node_ip_address",
     "get_node_ip_address",
     "remove_placement_group",
     "ray_debugpy",

src/ray/common/constants.h

@@ -64,7 +64,7 @@ constexpr int kMessagePackOffset = 9;
 constexpr char kSetupWorkerFilename[] = "setup_worker.py";
 
 /// The version of Ray
-constexpr char kRayVersion[] = "3.0.0.dev0";
+constexpr char kRayVersion[] = "2.32.0";
 
 /*****************************/
 /* ENV labels for autoscaler */