[Bugfix] Ray 2.9.x doesn't expose available_resources_per_node (#8767)

Signed-off-by: darthhexx <darthhexx@gmail.com>
This commit is contained in:
David Newman 2024-09-25 17:52:26 +10:00 committed by GitHub
parent 1ac3de09cd
commit 3368c3ab36
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -18,9 +18,14 @@ PG_WAIT_TIMEOUT = 1800
try:
import ray
from ray._private.state import available_resources_per_node
from ray.util import placement_group_table
from ray.util.placement_group import PlacementGroup
try:
from ray._private.state import available_resources_per_node
except ImportError:
# Ray 2.9.x doesn't expose `available_resources_per_node`
from ray._private.state import state as _state
available_resources_per_node = _state._available_resources_per_node
class RayWorkerWrapper(WorkerWrapperBase):
"""Ray wrapper for vllm.worker.Worker, allowing Worker to be