wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-27 20:06:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

Split out the part of get_node_ip_address for which the docstring is correct (#12796)

Browse Source
This commit is contained in:
dHannasch
2021-01-13 20:32:56 -07:00
committed by GitHub
parent 3f42e6bafe
commit ad015cb7df
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/_private/services.py
+7 -4
View File
@@ -373,7 +373,7 @@ def address_to_ip(address):
return ":".join([ip_address] + address_parts[1:])
def get_node_ip_address(address="8.8.8.8:53"):
def node_ip_address_from_perspective(address):
"""IP address by which the local node can be reached *from* the `address`.
Args:
@@ -383,9 +383,6 @@ def get_node_ip_address(address="8.8.8.8:53"):
Returns:
The IP address by which the local node can be reached from the address.
"""
if ray.worker._global_node is not None:
return ray.worker._global_node.node_ip_address
ip_address, port = address.split(":")
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
try:
@@ -409,6 +406,12 @@ def get_node_ip_address(address="8.8.8.8:53"):
return node_ip_address
def get_node_ip_address(address="8.8.8.8:53"):
if ray.worker._global_node is not None:
return ray.worker._global_node.node_ip_address
return node_ip_address_from_perspective(address)
def create_redis_client(redis_address, password=None):
"""Create a Redis client.